10.3.2. 用于追踪的 Kafka Streams 应用程序
本节论述了如何检测 Kafka Streams API 应用程序进行分布式追踪。
流程
在每个 Kafka Streams API 应用程序中:
将
opentracing-kafka-streams
依赖项添加到 Kafka Streams API 应用程序的 pom.xml 文件中:<dependency> <groupId>io.opentracing.contrib</groupId> <artifactId>opentracing-kafka-streams</artifactId> <version>0.1.15.redhat-00001</version> </dependency>
创建
TracingKafkaClientSupplier 供应商
界面的实例:KafkaClientSupplier supplier = new TracingKafkaClientSupplier(tracer);
为
KafkaStreams
提供供应商接口:KafkaStreams streams = new KafkaStreams(builder.build(), new StreamsConfig(config), supplier); streams.start();