15.2.3. 用于追踪的 Kafka Streams 应用程序
使用供应商接口检测 Kafka Streams 应用程序以进行分布式追踪。这启用了应用程序中的 Interceptors。
流程
在每个 Kafka Streams 应用程序中：
将
opentracing-kafka-streams依赖项添加到 Kafka Streams 应用程序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();
