kafkaのトピックの消費状況を確認する方法は何ですか？

1年 ago
優斗, 朝陽
1 minute

Kafkaのトピックの消費状況を確認するには、次の方法を使用できます。

  1. カフカのコンシューマーグループを管理するためのシェルスクリプト、kafka-consumer-groups.sh
kafka-consumer-groups.sh --bootstrap-server <bootstrap_servers> --list

は、Kafkaクラスタの起動サーバーリストです。

  1. kafka-consumer-groups.shを使用します。
kafka-consumer-groups.sh --bootstrap-server <bootstrap_servers> --describe --group <consumer_group>

は、確認したい消費者グループの名前です。

  1. kafka-run-class.sh を実行します。
kafka-run-class.sh kafka.tools.JmxTool --object-name kafka.consumer:type=consumer-fetch-manager-metrics,client-id=<client_id>,topic=<topic_name> --jmx-url service:jmx:rmi:///jndi/rmi://<kafka_host>:<jmx_port>/jmxrmi

は消費者のクライアントIDであり、は表示したいトピック名、はKafkaサーバーのホストアドレス、はKafkaサーバー上のJMXポートです。

Kafkaのトピックの消費状況を確認するためのさまざまな方法が提供されていますので、お客様のシナリオやニーズに最適な方法を選択してください。

bannerAds