KafkaのクライアントIDの設定方法

Kafkaでは、クライアントを識別するためにclient.idを設定してクライアントの一意の識別子を指定できます。client.idは、プロデューサーとコンシューマーの構成ファイルで設定できます。

プロデューサーの client.id は以下の方法で設定できます。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("client.id", "my-producer");

消費者に「client.id」を設定する方法：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");
props.put("client.id", "my-consumer");

Kafka サーバのログで特定のクライアントを追跡するには、client.id を設定します。これは、クラスタでクライアントを追跡してデバッグする場合に便利です。