グループごとに1人の消費者にメッセージが配信されますか？

Question

私は2つの消費者グループG1とG2を持っています。

1. G1には2つのメンバM1、M2があります。
2. G2は再び二つの部材M3、M4

G1ポーリングカフカトピックは、メッセージは両方ここで一つの部材M1又はM2のいずれにもない配信されますか？

同様に、G2がいつかポーリングしても、トピックについてのメッセージは引き続き検索されます。ここでもM3やM4が枯れていますか？

また、グループ内のすべてのメンバーが同じノード上にある必要があります。右 ？グループ内の特定のメンバーを選択するには、クライアントコードまたはKafkaの責任はありますか？

Answer 1

質問に対する回答は、これらのコンシューマグループが消費しているトピックにいくつのパーティションがあるかによって異なります。コンシューマ・グループの1つのメンバーだけが、トピックの各パーティションから読み取ることができます。

トピックT1にパーティションが1つしかない場合は、M1とM3はそこから読み取り、M2とM4はメッセージを受け取りません。

2つのパーティションはT1（P1およびP2と言う）である場合は、M1とM3はT1P1とM2とM4からメッセージを得るでしょうT1P2

からのメッセージになるだろうコンシューマ・グループのすべてのメンバーにはありません同じノード上にある必要があります

ブローカーの1人がグループのコーディネーターとして指定され、グループのメンバーとそのパーティションの割り当てを管理します。