Kafka 消费者 - JMX 属性

Question

我在端口 8081 上的 kafka 代理上启用了 JMX。当我在 jConsole 中查看 MBean 属性时，我只看到以下内容kafka.consumer-

kafka.consumer:type=FetchRequestAndResponseMetrics,name=FetchRequestRateAndTimeMs,clientId=ReplicaFetcherThread-2-413

kafka.consumer:type=FetchRequestAndResponseMetrics,name=FetchResponseSize,clientId=ReplicaFetcherThread-0-413

但这里在 Kafka Consumer Metrics 下确定的其他指标都不是由 JMX 发出的。

卡夫卡版本#0.8.2.1

我特别感兴趣的是 - kafka.consumer:type=ConsumerFetcherManager,name=MaxLag,clientId=([-.\w]+)

有什么想法吗？

Answer 1

您正在侦听的 JMX 端口是代理端口。但是kafka.consumer的Mbean：是消费者jvm指标。因此，如果您有另一个 JVM 正在使用某个主题，您可以看到 kafka.consumer Mbeans。