n 個のパーティションで構成されるトピックがあります。分散処理を行うために、異なるマシンで実行される 2 つのプロセスを作成します。同じグループ ID でトピックにサブスクライブし、n/2 スレッドを割り当てます。それぞれが単一のストリームを処理します (プロセスごとに n/2 パーティション)。
これで負荷分散が達成されますが、プロセス 1 がクラッシュした場合、プロセス 2 はプロセス 1 に割り当てられたパーティションからメッセージを消費できません。
または、HA を構成し、両方のプロセスで n スレッド/ストリームを開始すると、1 つのノードに障害が発生すると、すべてのパーティションが他のノードによって処理されます。しかし、ここでは、すべてのパーティションが一度に 1 つのノードによって処理されるため、分散に問題があります。
両方を同時に達成する方法はありますか?