16.2.3. 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();