カフカConsumerGroupは存在しません

Question

初めてカフカを設定すると、カフカ0.11。かなりのデフォルト設定を使用しています。プロデュースされたABCのトピックにいくつかのメッセージが生成されました。 2消費者は、同じトピックからのメッセージを消費するようにコード化されています。各消費者は異なるグループidのGROUP.1とGROUP.2に属します。

すべてのメッセージとオフセットの詳細については、トピックを参照してください。

kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group GROUP.1 

は

Error: The consumer group 'GROUP.1' does not exist.

同じエラーもGROUP.2ために、次のエラーがスローされます。私は昨日グループの1人にエラーなしで何か出力を得たが、今日はなかった。私は何が欠けているのですか？コンシューマグループの詳細を保持するように設定する必要があるか、または指定されたグループIDを持つコンシューマが現在実行されている場合にのみコマンドが機能するか、

私はkafka-consumer-groups --zookeeper localhost:2181 --describe --group GROUP.1を試しましたが、同じエラーが発生しました。

また、Kafka-consumer-offset-checkerコマンドも試してみました。

kafka-consumer-offset-checker --zookeeper localhost:2181 --topic ABC --group GROUP.1 

[2017-12-19 19:25:01,654] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$) Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/GROUP.1/offsets/ABC/2.

Answer 1

あなたは昨日のグループの詳細を見て言ったように、それはデフォルトのオフセットによってのみ24時間保存されていることを指摘し、おそらく価値があります。 24時間後にグループにオフセットがコミットされていない場合、カフカにはそれ以上の情報はありません。

実際に問題が発生した場合は、offsets.retention.minutesを大きな値に設定して時間を増やすことができます。