2017-01-19 1 views
0

私はkafkaを初めて使用しています。カフカを使用すると、retention.bytesを設定できます。メッセージの量が1GBに達すると、kafkaはメッセージを削除します。私はオフセットがゼロにリセットされることを尋ねますか? 2番目に、消費者はauto.offset.resetを最大に設定し、kafkaがメッセージを削除した後、消費者はどのオフセットを開始しますか?メッセージの量がretention.bytesのmaxsizeに達すると、kafkaはメッセージを削除し、オフセットはゼロにリセットされますか?

答えて

0

#1は、サイズベースポリシーと時間ベースポリシーの両方を考慮して、ログが新しい空のログセグメントにロールオーバーされる可能性があります。新しいログセグメントファイルの開始オフセットは、ログに追加される次のメッセージのオフセットになります。

あなたの質問#2のために、それは異なります。消費者によって追跡されたオフセットがメッセージの削除のために範囲外である場合、最大のオフセットにリセットされます。

関連する問題