kafkaの消費グループの状況をどう調べるか。

2年 ago
陽, 向宇
1 minute

Kafkaのコンシューマーグループの状況を確認するには、Kafkaに付属しているコマンドラインツールkafka-consumer-groups.shを使用できます。消費グループの状況を確認する手順は以下の通りです：

  1. 端末を開き、Kafkaのインストールディレクトリに移動してください。
  2. 実際のKafkaクラスターアドレスとコンシューマーグループIDにおよびを置き換えて、次のコマンドを実行してください。
bin/kafka-consumer-groups.sh --bootstrap-server <bootstrap_servers> --group <group_id> --describe
  1. 命令を実行すると、消費グループの状況が表示されます。これには、グループのメンバーや進捗状況、位置などの情報が含まれます。

例：出力例：

GROUP           TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID
my-group        my-topic        0          100             200             100             consumer-1-1a2b  192.168.1.100   consumer-1
my-group        my-topic        1          150             200             50              consumer-1-1a2b  192.168.1.100   consumer-1

上記の例では、トピックmy-topicの2つのパーティションを使用して消費グループmy-groupが消費していることがわかります。各パーティションの消費進捗、ログの最後のオフセット、遅延量が表示されます。さらに、各消費者の消費者ID、ホスト、クライアントIDも確認できます。

このコマンドラインツールを使えば、消費者グループの状態や消費者の進捗状況を簡単に確認し、監視やトラブルシューティングを行うことができます。

bannerAds