Selena, miembro de este equipo, nos ha hecho el favor de crear este post ya que controla perfectamente dicho tema.
Solución:
Usar kafka.tools.JmxTool
.
Suponiendo que ha habilitado JMX en su corredor en el puerto predeterminado de 9999, simplemente puede ejecutar este comando de ejemplo para imprimir métricas jmx para BrokerTopics a través de STDOUT
$ ./bin/kafka-run-class.sh kafka.tools.JmxTool
--object-name kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec
Trying to connect to JMX url: service:jmx:rmi:///jndi/rmi://:9999/jmxrmi.
"time","kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:Count","kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:EventType","kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:FifteenMinuteRate","kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:FiveMinuteRate","kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:MeanRate","kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:OneMinuteRate","kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:RateUnit"
1567587563143,0,messages,0.0,0.0,0.0,0.0,SECONDS
1567587565148,0,messages,0.0,0.0,0.0,0.0,SECONDS
1567587567150,0,messages,0.0,0.0,0.0,0.0,SECONDS
...
JmxTool
imprime métricas JMX cada --reporting-interval
opción.
–intervalo de informe
Intervalo (en milisegundos) con el que sondear las estadísticas de jmx
Defecto:
2000
(2 segundos)Valor de
-1
es equivalente a--one-time true
Descarga el jar que se encuentra aquí:
https://sourceforge.net/projects/cyclops-group/files/jmxterm/1.0-alpha-4/
En la máquina, luego ejecute:
wget https://sourceforge.net/projects/cyclops-group/files/jmxterm/1.0-alpha-4/ -o jmxterm.jar
java -jar jmxterm.jar
>open localhost:$jmx_port
La ayuda te dará lo que necesitas después de eso 🙂
Guarde este frasco en algún lugar útil, lo uso casi todos los días.