Kafka消费群体指标java

Question

我们希望获得Kafka消费群体指标（例如，节流和字节率）。

我们已经使用以下工具完成了此操作：

1. Kafka消费者Java应用程序的JMX Mbean
2. CLI实用程序：

bin/kafka-consumer-groups.sh--描述--组group_name--bootstrap-serverlocalhost： port

.

问题：这可以通过使用一些Java库以编程方式完成吗？

到目前为止，我们已经尝试

kafka.admin.ConsumerGroupCommand

bin/kafka bin/kafka-consumer-groups.sh也使用它，但我们只得到期望值的子集。

谢谢你的帮助。

Answer 1

您可以为消费者提供一个metric.reporters配置，该配置指向一个或多个实现org.apache.kafka.common.metrics.MetricsReport的类。来自Kafka源代码：

用作度量报告器的类的列表。实现组织。阿帕奇。Kafka。常见的韵律学。MetricsReporter接口允许插入将被通知创建新度量的类。始终包含JmxReporter以注册JMX统计信息。

还有几个项目可以为各种监控系统（如Prometheus）导出JMX度量。