Kafkaのトピックのデータ量を確認する方法
Kafkaトピックのデータ量を確認するには、以下2つの方法があります。
Kafka に組み込まれたツール kafka-consumer-groups.sh を使用します
- ターミナルを開き、Kafkaのインストールディレクトリに移動します。
- bin/kafka-consumer-groups.sh –bootstrap-server <Kafkaサーバーのアドレス:ポート> –describe –group
- kafkaサーバーアドレス:ポート
- 消費者団体
- コンシューマグループが購読する全トピックのオフセット情報(現在のオフセット、ログエンドオフセット(トピックの最新のメッセージのオフセット)、コンシューマーの位置など)を表示します。
方法2:Apache Kafkaに内蔵されているツール(kafka-run-class.sh)を使う
- ターミナルを開き、Kafka のインストールディレクトリに移動します。
- bin/kafka-run-class.sh kafka.tools.GetOffsetShell –broker-list <kafkaサーバーのアドレス:ポート> –topic <トピック名> –time -1
- Kafkaサーバーアドレス:ポート
- <トピック名>
- コマンドを実行すると、現在のオフセットやログエンドオフセット (トピックの最新のメッセージオフセットを表す) を含む、そのトピックのすべてのパーティションのオフセット情報が表示されます。
方法に関係なく、KafkaのTopic内のデータ量の情報を取得できます。