Spring引导执行器和千分尺所暴露的某些Kafka消费者指标没有标签/属性

Question

我已经配置了Spring引导执行器和千分尺，用于公开Kafka消费者度量标准。卡夫卡的一些指标没有“主题”标签。例如,

kafka_consumer_records_consumed_total_records_total{client_id="consumer-1",topic="topic1",} 0.0
kafka_consumer_records_consumed_total_records_total{client_id="consumer-2",topic="topic2",} 0.0
kafka_consumer_records_consumed_total_records_total{client_id="consumer-3",topic="topic3",} 0.0

kafka_consumer_commit_latency_max_seconds{client_id="consumer-1",} 0.013
kafka_consumer_commit_latency_max_seconds{client_id="consumer-2",} 0.013
kafka_consumer_commit_latency_max_seconds{client_id="consumer-3",} 0.013

我的问题是

是否需要配置来显示度量kafka_consumer_commit_latency_max_seconds?的“主题”标签？

1. 我注意到，即使在应用程序重新启动之后，client_id=“consumer 1”对于topic="topic1“也是一样的。我可以依靠client_id来始终指向特定的主题吗？

Answer 1

对于使用者来说，有些度量是全局的；有些是特定于主题的，还有一些是特定于主题/分区的。

client.id是固定的；当由kafka客户端生成时，不能保证您总是会得到相同的主题，但是您可以为每个消费者设置一个特定的ConsumerConfig.CLIENT_ID。