1. 修改Kafka安装目录下bin中kafka-run-class.sh 文件

增加如下内容

-Djava.rmi.server.hostname=10.139.12.15

增加后

# JMX settings
if [ -z "$KAFKA_JMX_OPTS" ]; thenKAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false  -Dcom.sun.management.jmxremote.ssl=false -Djava.rmi.server.hostname=10.139.12.15 "
fi

2. 修改bin中kafka-server-start.sh文件

增加如下内容：

export JMX_PORT="9988"

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; thenexport KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"export JMX_PORT="9988"
fi

3.启动kafka

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

4.使用JConsole链接