Отслеживать смещение Kafka Log с использованием JMX для старых групп

Question

Я пытаюсь отслеживать отставание потребителей для старых групп потребителей (которые используют zookeeper) с помощью JMX.

Вот так я включил JMX.

export KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Djava.rmi.server.hostname=`hostname -f` -Djava.net.preferIPv4Stack=true"
if [ "x$ISKAFKASERVER" == "xtrue" ]; then
export JMX_PORT=9887

И я могу видеть несколько бывших при подключении с помощью JConsole. Однако я не вижу kafka.consumer

Answer 1

Похоже, вы включили jmx на брокерах kafka. Вам нужно включить jmx в тех случаях, когда потребитель работает для получения метрик потребителя