我的团队最近在考虑为我们的项目使用不同的消息代理,我们最终选择了 Apache Pulsar,但它适用于其他人(Kafka)。我们的要求是跟踪发送给每个订阅者的消息总数和发送字节数以进行计费。
我正在阅读有关指标的文档,并惊讶地发现 Pulsar 没有跟踪这一点,我检查了 Kafka,结果是一样的。我对这个主题的理解很少,所以这是某种反模式吗?我知道像这样的计数器值永远不会下降,对于我们的用例 - 不应该重置,导致潜在的(某些)溢出。但对我来说,这可以通过在 Prometheus 中使用直方图(Pulsar 中使用的度量格式)来解决。我实际上正在考虑实现这样的功能,但我错了,是否有更好的解决方案来满足我们的目的?