2017-09-19 6 views

答えて

1

各コンシューマ/プロデューサは、コンシューマ/プロデューサが読み書きするパーティションのリーダーであるブローカに接続する必要があります。 これは、クライアントがクラスタ内のすべてのブローカに接続する必要はなく、メッセージの読み取り/送信に必要なブローカだけに接続することを意味します。 初期設定時には、接続するブローカのリストを提供します(1つでも可能です)。そのようなブローカーを使用して、クライアントは、使用したいトピック/パーティションに関するメタデータ情報を取得します(クラスタ内の他のブローカー)。このような接続は、クライアントが目的のトピック/パーティションで作業するために必要です。

+0

brokers-listのブローカの1人に初期設定のプロデューサ/コンシューマを接続すると、プロデューサ/コンシューマを閉じるまでその接続が有効になりますか?メッセージがパーティションのリーダに対して読み書きされると、クライアントから読み書きされた直後に接続が閉じられるか、プロデューサ/コンシューマが閉じられるまで接続が閉じられますか?コンシューマ/プロデューサは、複数のパーティションのリーダーである1つのブローカに対して複数の接続を行いますか? –

+0

一般的な答えはノーです。消費者がトピックを残しているブローカに接続しなくても、消費者がオフセットをコミットするために使用する__consumer_offsetsトピックのパーティション(デフォルトでは50個のパーティション)がそのブローカに含まれるためです。プロデューサの観点から見ると、プロデューサがトピックが別のものであるために "間違った"ブローカに接続すると、接続が閉じられている可能性があります。 – ppatierno

+0

は、初期設定のためにプロデューサ/コンシューマによる接続についてより明確に説明できます。 –

関連する問題