客户端和用户的Kafka配额

Question

我对Kafka很陌生，我想了解配额制是如何为Kafka工作的。

到现在为止我一直在跟踪这里的文件

bin/kafka-configs.sh--zookeeper 10.11.10.2:2181--alter--add-config'producer_byte_rate=1024,consumer_byte_rate=1024'--实体类型客户端--实体名称客户端A

我还使用以下命令来测量Kafka主题的吞吐量

bin/kafka-producer-perf-test.sh--topic topic1--num-records 100000--record-size 100000--吞吐量500000--producer-props acks=0 bootstrap.servers=10.11.10.2:9092

现在我不确定如何为特定的生产者分配客户端ID。基本上，我想用一个特定的客户端ID运行kafka-producer-perf-test。

有没有可能这样做。另外，用户配额和客户端配额之间有什么区别？我可以将用户ID分配给一个特定的生产者吗？

Answer 1

根据kafka-producer-test.sh调用的kafka.tools.ProducerPerformance的源代码，“client.id”是使用“producer-performance”硬编码的（至少在0.10版和更早版本中）。如果运行kafka-producer-perf-test脚本，则必须为该特定客户端设置配额。