通過JMX自定義監控
通過JMX監控可以看到的數據有:
- broker數據指標
- topic數據指標
- 每個partition的數據指標
- consumer消費滯后情況等。
方法一
要啟用JMX關鍵在於對變量$JMX_PORT賦值,直接在kafka啟動腳本kafka-server-start.sh增加一句:
export JMX_PORT="9999"
- 1

nohup bin/kafka-server-start.sh config/server.properties &
- 1
方法二
在使用jmx之前需要確保kafka開啟了jmx監控,kafka啟動時要添加JMX_PORT=9999這一項
通過JMX_PORT 指定連接jmx的端口號
JMX_PORT=9999 nohup bin/kafka-server-start.sh config/server.properties &
- 1

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端口)
