2017-06-20 24 views
0

私は、2人の消費者がグループg1に属するc1とグループg2に属するc2を持っています。 私は100件のメッセージで話題をテストしています。 c1がメッセージを読み取り、自動コミットが有効になっています。 今、私がc2を開始すると、オフセット0から消費され始めますか?もしそうなら、私は別のグループのメッセージを最初から消費することができません。同じ話題から消費する複数の消費者

答えて

0

消費者オフセットは消費者が独自に管理しています。

シナリオでは、コンシューマは同じトピックを消費する2つの異なるグループに存在するため、どこにもオフセットが格納されていないため、新しいコンシューマの動作はauto.offset.resetの設定に依存します。最小に設定されている場合、新しいコンシューマはトピックの先頭(最小)またはトピックの最後(最大)から開始します。

+0

異なるグループの消費者は、コミットオフセットを個別に維持していますか? – codehacker

+0

すべての消費者は、オフセットを個別に維持します。彼らが同じグループにいるとしても。 __consumer_offsetトピックと呼ばれる別のトピックがあります。ここでは、コンシューマのコミットされたオフセットのグループごとにパーティションを見つけることができます。 –

+0

トピックの各パーティションは、特定のグループ内の唯一のコンシューマによって消費される可能性がありますが、別々のグループにある場合は複数のコンシューマによって消費される可能性があります。 –

関連する問題