kafka（0.10.x）からグループコミットオフセットを取得する方法

Question

グループのオフセット情報は、以前に飼い猫に保存されていました。現在、Kafka Cluster（0.10.x）では、オフセット情報は、名前が__consumer_offsetsのトピックに格納されています。

しかし、どのように、私はオフセットを取得するには、以下のコマンドを起動し、私はアクティブなグループのために

Answer 1

指定されたグループのオフセット情報を得ることができます：？を非アクティブグループの場合

bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --describe --group test-consumer-group 

、最初の目標を取得しますMath.abs（groupId.hashCode（））50％を計算することにより、トピック・パーティション番号をオフセットし、呼び出し：

bin/kafka-simple-consumer-shell.sh --topic __consumer_offsets --partition <calculated number> --broker-list broker1:9092 --formatter "kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter" 

を

グループのオフセットを見つけること。