kafkaコマンドを使用してトピックの消費状況を確認する方法は？

1年 ago
桜, 春樹
1 minute

トピックの消費状況を確認するためには、Kafkaコマンドを使用して以下のコマンドを実行できます。

  1. 消費者のグループ情報を確認する。
kafka-consumer-groups.sh --bootstrap-server <kafka服务器地址> --group <消费者组名称> --describe

指定された消費者グループの消費者の詳細情報が表示されます。これには、現在の消費トピック、消費オフセットなどが含まれます。

  1. 特定トピックの消費者オフセットを確認する:
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <kafka服务器地址> --topic <topic名称> --time -1

与指定topic的每个部分的使用者移位一同显示。

  1. 特定のトピックに関する消費者グループの消費状況を確認する。
kafka-consumer-groups.sh --bootstrap-server <kafka服务器地址> --group <消费者组名称> --topic <topic名称> --describe

この機能は、特定のトピックにおける特定の消費者グループの消費状況を表示し、各消費者のオフセットとラグ（最新メッセージからのオフセットの差）を含めます。

実際の値に<kafkaサーバーアドレス>、<コンシューマーグループ名>、<トピック名>を置き換えるようにしてください。

bannerAds