azure-sqldw-sink-connector
build-a-streaming-pipeline
export-import-with-kafkacat
getting-started-with-ccloud-golang
getting-started-with-ccloud-java
kafka-connect-zero-to-hero
ksql-udf-advanced-example
mqtt-connect-connector-demo
multi-cluster-connect-and-ksql
mysql-debezium-ksql-elasticsearch
oracle-ksql-elasticsearch
postgres-debezium-ksql-elasticsearch
rail-data-streaming-pipeline
scalable-payment-processing
Folders and files Name Name Last commit message
Last commit date
parent directory Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
Dec 29, 2019
View all files
Distributed Tracing for Stream Processing
Preamble of a document - TBD
Prep, download and Build everything
producer.interceptor.classes =io.confluent.devx.util.KafkaTracingProducerInterceptor
consumer.interceptor.classes =io.confluent.devx.util.KafkaTracingConsumerInterceptor
export JAEGER_SERVICE_NAME=DemoInterceptors
export INTERCEPTORS_CONFIG_FILE=/etc/jaeger/ext/interceptorsConfig.json
You can’t perform that action at this time.