SOA アプリケーションには次のシナリオがあります。ServiceA は、ServiceB のインスタンスによって非同期的に処理される必要があるいくつかのジョブを生成します。基本的に、これは、各ワーカーが ServiceB のインスタンスであるワーク キューの問題につながります。メッセージブローカーとして Kafka を使用しており、次の設定があります。
5 ブローカー B1、B2、B3、B4、および B5。10 個のパーティション (P1、P2、....P10) を持つトピック (A) があり、それぞれのレプリケーション ファクターは 3 です。パーティションの割り当てが次のようであると仮定します。レプリカとしての B(i+1) および B(i+2)。
ServiceB の 3 つのインスタンスが実行されています。このセットアップが与えられた場合、C1 が 3 つのパーティションから消費する消費モデルを実現するために、高レベル コンシューマー API をどのように使用すればよいでしょうか。3 つのパーティションからの C2。残りの 4 つのパーティションからの C3