Looking for apache-kafka Answers? Try Ask4KnowledgeBase
Looking for apache-kafka Keywords? Try Ask4Keywords

apache-kafka消費者グループとオフセット管理


パラメーター

パラメータ説明
group.id コンシューマー・グループの名前。
enable.auto.commit 自動的にオフセットをコミットします。 デフォルト:true
auto.commit.interval.ms コミットするまでの最小遅延(ミリ秒)( enable.auto.commit=trueが必要)。 デフォルトは5000です。
auto.offset.reset 有効なコミットされたオフセットが見つからない場合の対処方法。 デフォルト:最新 (+)
(+)可能な値 説明
早い最も早いオフセットに自動的にオフセットをリセットします。
最新オフセットを最新のオフセットに自動的にリセットします。
無しコンシューマのグループに対して以前のオフセットが見つからない場合、コンシューマに例外をスローします。
他に何か消費者に例外を投げる。

消費者グループとオフセット管理 関連する例