go - 使用 confluent-kafka-go 获取 kafka 代理、消费者、生产者指标

Question

我找不到有关获取指标的实现的任何参考。有人可以提供示例和参考吗？

Answer 1

正如stats_example在这里所说，您可以获得 STATISTICS.md 中列出的统计信息。但在示例注释中明确提到，您需要实现指标

Stats 事件作为 JSON（作为字符串）发出。直接将 JSON 转发到您的统计信息收集器，或将其转换为地图以提取感兴趣的字段。

所以在这种情况下，在您的应用程序中，您需要实现指标收集器，例如prometheus

如果您想要完整的代理端指标，您可以实施 Kafka 监控，正如 Kafka 文档在此处解释的那样

Kafka 使用 Yammer Metrics 在服务器中报告指标。Java 客户端使用 Kafka Metrics，这是一个内置的指标注册表，可以最大限度地减少引入客户端应用程序的传递依赖。两者都通过 JMX 公开指标，并且可以配置为使用可插入的统计报告器报告统计信息以连接到您的监控系统。