2017-04-14 1 views
1

コンシューマーコードを実行する新しいマシン/プロセスをスピンアップしてコンシューマーを特定のトピックにスケールアップしたい場合は、コンシューマーコードを実行するすべてのマシン/プロセス)は同じ消費者グループIDを使用しますか?そしてカフカはすべての調整を処理しますか?マシン/プロセス間でカフカの消費者を拡大する

(消費者よりもトピックに複数のパーティションがあると仮定)

ただ、私の理解を確認したいです。

答えて

2

はい、それは簡単です!

消費者がコンシューマ・グループに加わるか、コンシューマ・グループから離れると、Zookeeperに自動的に登録され、新しい消費者プール内の負​​荷を再分配するプロセスがトリガーされます。

関連する問題