1
コンシューマーコードを実行する新しいマシン/プロセスをスピンアップしてコンシューマーを特定のトピックにスケールアップしたい場合は、コンシューマーコードを実行するすべてのマシン/プロセス)は同じ消費者グループIDを使用しますか?そしてカフカはすべての調整を処理しますか?マシン/プロセス間でカフカの消費者を拡大する
(消費者よりもトピックに複数のパーティションがあると仮定)
ただ、私の理解を確認したいです。
コンシューマーコードを実行する新しいマシン/プロセスをスピンアップしてコンシューマーを特定のトピックにスケールアップしたい場合は、コンシューマーコードを実行するすべてのマシン/プロセス)は同じ消費者グループIDを使用しますか?そしてカフカはすべての調整を処理しますか?マシン/プロセス間でカフカの消費者を拡大する
(消費者よりもトピックに複数のパーティションがあると仮定)
ただ、私の理解を確認したいです。
はい、それは簡単です!
消費者がコンシューマ・グループに加わるか、コンシューマ・グループから離れると、Zookeeperに自動的に登録され、新しい消費者プール内の負荷を再分配するプロセスがトリガーされます。