Kafka

このページの内容は古くなっている可能性があり、一部のリンクが無効になっている場合があります。 このページのより新しいバージョン英語版にあります。

詳細情報 ...

このページが最後に更新されてからの英語ページの変更を確認するには、 GitHub compare 36a8a53c..10fe33751 にアクセスし、content/en/docs/demo/services/kafka.md を検索してください。

これはチェックアウトサービスと会計サービスおよび不正検知サービスを接続するためのメッセージキューサービスとして使用されます。

Kafka サービスのソースコード

自動計装

このサービスは、OpenTelemetry Java エージェントと組み込みの JMX Metric Insight Module を使用して、Kafka ブローカーメトリクスをキャプチャし、OTLP 経由で Collector に送信します。

エージェントは -javaagent コマンドライン引数を使用してプロセスに渡されます。 コマンドライン引数は Dockerfile 内の KAFKA_OPTS を通じて追加されます。

ENV KAFKA_OPTS="-javaagent:/tmp/opentelemetry-javaagent.jar -Dotel.jmx.target.system=kafka-broker"