go - 使用 confluent-kafka-go 获取 kafka 代理、消费者、生产者指标
问题描述
我找不到有关获取指标的实现的任何参考。有人可以提供示例和参考吗?
解决方案
正如stats_example在这里所说,您可以获得 STATISTICS.md 中列出的统计信息。但在示例注释中明确提到,您需要实现指标
Stats 事件作为 JSON(作为字符串)发出。直接将 JSON 转发到您的统计信息收集器,或将其转换为地图以提取感兴趣的字段。
所以在这种情况下,在您的应用程序中,您需要实现指标收集器,例如prometheus
如果您想要完整的代理端指标,您可以实施 Kafka 监控,正如 Kafka 文档在此处解释的那样
Kafka 使用 Yammer Metrics 在服务器中报告指标。Java 客户端使用 Kafka Metrics,这是一个内置的指标注册表,可以最大限度地减少引入客户端应用程序的传递依赖。两者都通过 JMX 公开指标,并且可以配置为使用可插入的统计报告器报告统计信息以连接到您的监控系统。
推荐阅读
- ios - SwiftUI,如何在不重新创建视图的情况下切换到视图?
- javascript - discord.js 检查特定用户 ID 是否具有特定角色 ID
- sql - SQL (Postgres):ON vs WHERE 以获得更好的性能
- r - 用变量连接字符串
- node.js - 如何在 Nix Docker Tools 映像中包含我的源代码?
- node.js - 使用busboy的Nodejs可恢复文件上传
- django - Django SearchVector postgres searchvector没有保存正确的字符串
- mongodb - 我想根据发生时间查询集合中定义的持续时间之间的持续会议
- sql - 比较列但排除特定对
- ios - SwiftUI 删除 ForEach 子视图中的数组条目