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