カフカ消費者 - JMXプロパティ

Question

私はJConsoleの内のMBeanのプロパティを表示すると、私は唯一のkafka.consumerために以下を参照してください。ポート8081上カフカブローカーにJMXを有効に -

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

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

しかし、他のもののどれもKafkaの下でhereで識別されます。Consumer MetricsはJMXによって発行されます。

カフカバージョン＃私が特に興味を持って0.8.2.1

- kafka.consumer:type=ConsumerFetcherManager,name=MaxLag,clientId=([-.\w]+)

任意の考え？

Answer 1

これは0.8の値を見つけるのに役立ちますが、現在はKafka 0.10ブローカーとコンシューマーを実行しています。コンソールコンシューマを使用しているとき、kafka.consumer - >consumer-fetcher-manager-metric - >consumer-1 - >Attributes - >records-max-lagのように、このコンシューマにjconsoleと指摘しました。

Answer 2

あなたが聞いているJMX PORTは、ブローカーポートです。しかし、kafka.consumerのMbeanは消費者のjvmメトリクスです。したがって、トピックを消費する別のJVMがある場合は、kafka.consumer Mbeanが表示されます。