2016-05-26 11 views
2

特定の消費者グループがトピックを完全に消費したかどうかを確認する方法はありますか?
これは、標準キューイングシステムでキューが空であるかどうかをチェックするのと同じです。
これは、各コンシューマが与えられたパーティションのみを表示するため、グループ内の他のコンシューマがそれらのパーツを消費したかどうかはわかりません。
これはどういうわけかAdminUtilsまたはZkUtilsで行うべきだと思いますが、正しい方法を見つけることはできません。トピックがKafkaの消費者によって消費されたかどうかを確認する方法

答えて

4

kafka-consumer-groups.shを使用して消費者オフセットを確認してください。
(kafka-consumer-offset-checker.shは、同様の機能を持っていますが、0.9.0.0で廃止されました。)

ビン/ kafka-consumer-groups.sh --bootstrapサーバーXXX:9092- - 基 XXX-グループID --describe --newコンシューマ
GROUPトピックPARTITION CURRENTオフセットLOG-ENDオフセットLAGの所有者がconsumer.test.0529.095217 secured_topic 0 586 3333 2747消費者1_/10.139.0.4 consumer.test.0529.095217 secured_topic 3334 3334 0 consumer-1_/10.139.0.4 consumer.test.0529.095217 secured_topic 2 0 3333 3333 consumer-1_/10.139.0.4

関連する問題