Kafka Consumer - JMX Eigenschaften

Question

ich JMX auf den kafka Broker auf Port aktiviert 8081. Wenn ich die MBean Eigenschaften in JConsole sehen, sehe ich nur die folgenden für kafka.consumer -

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

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

Aber keiner der anderen diejenigen, die werden in here unter Kafka Consumer Metrics von JMX emittiert.

Kafka Version # 0.8.2.1

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

Irgendwelche Gedanken?

Answer 1

Dies kann helfen, es für 0,8 zu finden, aber ich bin derzeit ein Kafka 0.10 Broker und Verbraucher. Bei Verwendung eines Konsolenverbrauchers habe ich diesen Consumer auf jconsole gerichtet und auf dem MBeans-Tab: kafka.consumer ->consumer-fetcher-manager-metric ->consumer-1 ->Attributes ->records-max-lag gefunden.

Answer 2

Der JMX PORT, den Sie hören, ist der Broker-Port. Aber die Mbean von kafka.consumer: ist der Verbraucher jvm Metriken. Wenn Sie also eine andere JVM verwenden, die ein Thema verwendet, können Sie kafka.consumer Mbeans sehen.