0
私は、2人の消費者がグループg1に属するc1とグループg2に属するc2を持っています。 私は100件のメッセージで話題をテストしています。 c1がメッセージを読み取り、自動コミットが有効になっています。 今、私がc2を開始すると、オフセット0から消費され始めますか?もしそうなら、私は別のグループのメッセージを最初から消費することができません。同じ話題から消費する複数の消費者
私は、2人の消費者がグループg1に属するc1とグループg2に属するc2を持っています。 私は100件のメッセージで話題をテストしています。 c1がメッセージを読み取り、自動コミットが有効になっています。 今、私がc2を開始すると、オフセット0から消費され始めますか?もしそうなら、私は別のグループのメッセージを最初から消費することができません。同じ話題から消費する複数の消費者
消費者オフセットは消費者が独自に管理しています。
シナリオでは、コンシューマは同じトピックを消費する2つの異なるグループに存在するため、どこにもオフセットが格納されていないため、新しいコンシューマの動作はauto.offset.resetの設定に依存します。最小に設定されている場合、新しいコンシューマはトピックの先頭(最小)またはトピックの最後(最大)から開始します。
異なるグループの消費者は、コミットオフセットを個別に維持していますか? – codehacker
すべての消費者は、オフセットを個別に維持します。彼らが同じグループにいるとしても。 __consumer_offsetトピックと呼ばれる別のトピックがあります。ここでは、コンシューマのコミットされたオフセットのグループごとにパーティションを見つけることができます。 –
トピックの各パーティションは、特定のグループ内の唯一のコンシューマによって消費される可能性がありますが、別々のグループにある場合は複数のコンシューマによって消費される可能性があります。 –