0
Javaクライアントで生成して使用する間に、接続数やプロデューサーとコンシューマーがKafkaクラスターに対して行った接続の種類については、誰かが分かります。 クラスタ内のトピックまたはパーティションまたはブローカに基づいた接続数はありますか?生産者と消費者はカフカのクラスタにいくつ接続していますか?
Javaクライアントで生成して使用する間に、接続数やプロデューサーとコンシューマーがKafkaクラスターに対して行った接続の種類については、誰かが分かります。 クラスタ内のトピックまたはパーティションまたはブローカに基づいた接続数はありますか?生産者と消費者はカフカのクラスタにいくつ接続していますか?
各コンシューマ/プロデューサは、コンシューマ/プロデューサが読み書きするパーティションのリーダーであるブローカに接続する必要があります。 これは、クライアントがクラスタ内のすべてのブローカに接続する必要はなく、メッセージの読み取り/送信に必要なブローカだけに接続することを意味します。 初期設定時には、接続するブローカのリストを提供します(1つでも可能です)。そのようなブローカーを使用して、クライアントは、使用したいトピック/パーティションに関するメタデータ情報を取得します(クラスタ内の他のブローカー)。このような接続は、クライアントが目的のトピック/パーティションで作業するために必要です。
brokers-listのブローカの1人に初期設定のプロデューサ/コンシューマを接続すると、プロデューサ/コンシューマを閉じるまでその接続が有効になりますか?メッセージがパーティションのリーダに対して読み書きされると、クライアントから読み書きされた直後に接続が閉じられるか、プロデューサ/コンシューマが閉じられるまで接続が閉じられますか?コンシューマ/プロデューサは、複数のパーティションのリーダーである1つのブローカに対して複数の接続を行いますか? –
一般的な答えはノーです。消費者がトピックを残しているブローカに接続しなくても、消費者がオフセットをコミットするために使用する__consumer_offsetsトピックのパーティション(デフォルトでは50個のパーティション)がそのブローカに含まれるためです。プロデューサの観点から見ると、プロデューサがトピックが別のものであるために "間違った"ブローカに接続すると、接続が閉じられている可能性があります。 – ppatierno
は、初期設定のためにプロデューサ/コンシューマによる接続についてより明確に説明できます。 –