apache-kafka - 如何将客户端 ID 分配给特定的 kafka 生产者或主题？

Question

我知道配额基于客户端 ID

基本上我想用特定的客户端 ID 运行 kafka-producer-perf-test 来测试配额是否正常工作

我的问题是如何为特定的生产者(或)分区分配客户端 ID？

Answer 1

创建生产者时，您可以为 client.id 属性分配一个唯一值。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("client.id", "testclient001");
//set any additional properties.

Producer<String, GenericRecord> producer = new KafkaProducer<String, GenericRecord>(props);