有任何API或工具可以在Kafka主题中获取摄入率

Question

在其他答案中提到的是，KAFKA通过JMX导出指标，该指标涵盖/输出率以及许多其他有趣的数据点。有关全部详细信息，请参见文档中的

Answer 1

。 建议您收集和绘制您的任何这些指标都计划运行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）可以看到Prometheus中的指标。 您将在那里获得主题级别的指标，您可以在每个主题中看到每秒/分钟的摄入

您可以使用

Https：//github.com/sivann/kafkatop

监视主题/消费者组上的实时消息率，这是一个tui.

Answer 2