kafka主题中是否有任何API或工具来获取摄入率

2024-05-18 • 问答

如何找到摄入率？也就是说，每秒钟/分钟的时间间隔内不会提取事件/字节数

如另一个答案中所述，Kafka通过JMX导出指标，该指标涵盖字节输入/输出速率以及许多其他有趣的数据点。有关完整的详细信息，请参阅文档中的Monitoring section。

建议您在计划运行Kafka集群时收集并绘制所有这些指标的图形。

现在，如果您只是想在开发过程中快速获得这些值，则还有其他两种选择：

jconsole：此图形工具随JVM一起提供，并且可以显示所有JMX指标。
kafka.tools.JmxTool：该CLI工具是Kafka随附的，可以打印JMX指标的值。例如，要获取代理摄取率，请运行：
```
./bin/kafka-run-class.sh kafka.tools.JmxTool --object-name kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec
```

要使它们起作用，必须使JVM能够在端口上公开JMX。

您可以在kafka设置中使用jmx导出器，然后将抓取的指标发送到prometheus（时间序列db）。

然后可以在grafana中可视化普罗米修斯的度量。您将在那里获得主题级别的指标，您可以在其中查看每个主题的每秒/分钟的摄取量