2

我一直在尝试使用 go sarama 库获取 kafka 代理指标，但我没有什么顾虑。

我使用 sarama.NewConfig() 初始化了一个 sarama 配置，版本为 sarama.V2_0_0_0 ，我使用这个配置来获取他们文档中提到的指标

`metrics.GetOrRegisterMeter("incoming-byte-rate", config.MetricRegistry).RateMean()`

  1. 这是否提供包括所有传入消息在内的总传入字节率？因为我将此值与镜头和其他工具进行了比较，但它完全不同（“传出字节率”和“请求率”相同。我想这个请求率意味着消息率）。

  2. 与RateMean()函数不同，Rate1(),Rate5()和Rate15()只返回 0 尽管在 kafka 集群中有很多活动。你知道这是什么原因吗？

  3. 我曾经获得文档metrics.GetOrRegisterMeter(fmt.Sprintf("incoming-byte-rate-for-broker-%v", broker.ID()), config.MetricRegistry).RateMean()中提到的经纪人级别指标， 但我只收到 0。

如果有人可以在这里帮助我并启发我解决这些问题，我将非常感激。提前致谢。:)

4

0 回答 0