kafkaからコンシューマオフセットを読み取るツール0.9

Question

私はKafka 0.9コンシューマAPIを使用しています。特定のコンシューマ・グループとトピックのコンシューマの現在のオフセットを確認し、この情報をリストするコマンドライン・ツールが見つからないようにする必要があります。私は次のコマンドを試しました

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group <group_name> 

しかし、コンシューマーが稼働している/ポーリングしている場合でも、これはリストには表示されません。

Kafka 0.9 new consumer api --- how to just watch consumer offsetsに基づいて、このためのコマンドラインツールがあるようですが、これがKafka 0.9の消費者であるかどうかわかりません。

ご協力いただければ幸いです。

Answer 1

これは私の作品：

bin/kafka-consumer-groups.sh --new-consumer --describe --group ta-services --bootstrap-server localhost:9092 

、結果としてこのようなものを与える：

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER 
ta-services, modsec_logs, 0, 2, 2, 0, instance1-0_/127.0.0.1 
ta-services, modsec_logs, 1, 9, 9, 0, instance1-0_/127.0.0.1 
ta-services, modsec_logs, 2, 1, 1, 0, instance1-1_/127.0.0.1 
ta-services, modsec_logs, 3, 1, 1, 0, instance1-1_/127.0.0.1 

は、このコマンドは、あなたの消費者がアップしているのみ時に動作するように思われること、覚えておいてください生きている。停止するとすぐに、コマンドからの出力は得られません。これは、0.9.xと0.8.xのオフセットチェッカーの欠点の1つと考えています。私はまだ0.9で "死んだ"消費者のオフセットをチェックする方法を見つけることができませんでした（スクリプトを使って、手動で_offsets ...トピックからデータを読み取ることなく） - 誰かがそれを行う方法を知っていれば、投稿してください！