通过JMX自定义监控

kafka开启JMX

通过JMX监控可以看到的数据有：

• broker数据指标
• topic数据指标
• 每个partition的数据指标
• consumer消费滞后情况等。

方法一

Kafka开启JMX

要启用JMX关键在于对变量$JMX_PORT赋值，直接在kafka启动脚本kafka-server-start.sh增加一句：

export JMX_PORT="9999"

nohup bin/kafka-server-start.sh config/server.properties &

方法二

在使用jmx之前需要确保kafka开启了jmx监控，kafka启动时要添加JMX_PORT=9999这一项
通过JMX_PORT 指定连接jmx的端口号

JMX_PORT=9999 nohup bin/kafka-server-start.sh config/server.properties &

1、jconsole

利用jconsole 工具：（可通过jconsole，找到Mbean对应的指标，鼠标悬浮指标上方就能找到代码查询所需的ObjectName。）
可以在JDK安装的bin目录中找到jconsole

或者
win+r

前提是你配了JDK的环境路径

查看kafka broker端的信息

本地直接连接kafka进程

通过远程连接进程：service:jmx:rmi:///jndi/rmi://127.0.0.1:9999/jmxrmi（启动kafka时需开通JMX端口）

公有云双ip环境

https://documentation.bonitasoft.com/bcd/3.4/how_to_enable_remote_monitoring_jmx

bonita_java_opts: >-
  -Djava.awt.headless=true
  -Xms1024m
  -Xmx1024m
  -XX:+UseConcMarkSweepGC
  -Dcom.sun.management.jmxremote=true
  -Dcom.sun.management.jmxremote.port=9010
  -Dcom.sun.management.jmxremote.rmi.port=9010
  -Dcom.sun.management.jmxremote.local.only=false
  -Dcom.sun.management.jmxremote.authenticate=false
  -Dcom.sun.management.jmxremote.ssl=false
  -Djava.rmi.server.hostname={{ ec2_public_dns_name | default(ansible_fqdn) }}

export JMX_PORT=9999; export KAFKA_HEAP_OPTS="-Xmx8G -Xms8G"; export KAFKA_JMX_OPTS="-Djava.rmi.server.hostname=10.253.51.157 -Dcom.sun.management.jmxremote.rmi.port=9999 -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false";

如果不指定 -Djava.rmi.server.hostname=10.253.51.157 或是会使用jmx连接kafka节点 host为localhost对应的地址。
如果不指定 -Dcom.sun.management.jmxremote.rmi.port=9010会在 1024-65535中随机产生