如何加载我的卡夫卡主题.有没有API可以用来测量我的Kafka主题的负载

Question

我的spring-boot应用程序上有一个Kafka主题，我正在从生产者那里发送一些数据。我想检查我的主题的负载，这样我就可以创建新的主题，如果上一个主题的负载超过

Answer 1

主题没有"负载"；在传统意义上。当然，您可以使用JMX度量来测量传入字节率，但这是由broker测量的网络负载。您还可以按生产者测量每个分区的传出速率，并聚合以按主题获取数据。

托管分区的代理程序确实有负载；可测量的网络、磁盘和CPU负载。

其次，你的制作人都需要更新，才能真正向你创建的新主题发送数据；他们和经纪人都不知道"；分配负载"；他们。

减少代理负载并将数据分发给更多代理的正确方法是增加集群大小，而扩展生产的正确方法则是添加更多分区。