Spring靴致动器和千分尺暴露的一些Kafka消费者指标没有标签/属性

Question

我已经配置了Spring启动执行器和千分尺，用于公开Kafka消费者指标。某些 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

我的问题是

> < li>

显示指标Kafka _ consumer _ commit _ latency _ max _ seconds的“主题”标签是否需要任何配置？

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

Answer 1

有些指标对消费者来说是全球性的；有些特定于一个主题，有些特定于一个主题/分区。

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