10.3.2. 用于追踪的 Kafka Streams 应用程序

将 opentracing-kafka-streams 依赖项添加到 Kafka Streams API 应用程序的 pom.xml 文件中：

<dependency>
    <groupId>io.opentracing.contrib</groupId>
    <artifactId>opentracing-kafka-streams</artifactId>
    <version>0.1.12.redhat-00001</version>
</dependency>

创建 TracingKafkaClientSupplier 供应商 界面的实例：

KafkaClientSupplier supplier = new TracingKafkaClientSupplier(tracer);

为 KafkaStreams 提供供应商接口：

KafkaStreams streams = new KafkaStreams(builder.build(), new StreamsConfig(config), supplier);
streams.start();