16.2.3. Kafka Streams アプリケーションのトレース用のインストルメント化
サプライヤーインターフェイスを使用して、分散トレーシングのために Kafka Streams アプリケーションをインストルメント化します。これにより、アプリケーションのインターセプターが有効になります。
手順
各 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();
