kafkaマルチノードセットアップアクティブ - アクティブ

Question

私はkafkaを初めて使い、いくつかの基本的な疑問があります。 私はマルチノードカフカをセットアップしようとしていました（Active-Active）。ここでのシナリオは次のとおりです。 -

1. 単一のZooKeeperを実行している（ポート：2181）
2. が開始3カフカブローカー（9092,9093,9094）
3. 単一のトピックのテストを作成します（パーティション：1、複製3）
4. ブローカーリスト（9092,9093）を使用してプロデューサーを開始しました。
5. 9092,9093,9094でコンシューマーを開始しましたが、すべて同じトピックを使用しています。

私はそれがすべての3人の消費者、

Q1で消費される生産者からのメッセージを送信していたときに今、私の疑問は、あります。それはメッセージを複製しているということですか？

q2。プロデューサが9092,9093で動作している場合、ポート9094のコンシューマがメッセージを消費しているのはなぜですか？それは同じトピック名を使用しているからですか？

q3。私がプロデューサからメッセージを送信しているときに、それを単一の消費者が消費すべきであることをどのように確認できるか？ （私はグループ化を試みましたが、消費者が異なるグループにいる場合、メッセージを受信して​​います）。

q4。私が消費者の間でメッセージを配布したいのであれば、これをどのように達成できますか？

q5。単一のプロデューサと複数のコンシューマを使用してマルチノードkafka（Active-Active）を設定する他の方法はありますか？

ご了承ください。

Answer 1

私はコメントで答えましたが、これは本当にカフカの消費者グループについての理解の欠如につながる質問です。このフォーマットで議論するには時間がかかりすぎますので、ここで指示しますhttps://kafka.apache.org/documentation/#theconsumer