Kafka JMX配置账号密码访问

进入kafka安装目录，假如我的kafka安装路径为/home/xiaozhongcheng/kafka

cd /home/xiaozhongcheng/kafka

新增账号密码文件

在/home/xiaozhongcheng/kafka目录下新增如下文件，并添加如下内容

jmxremote.access

monitorRoleUser readonly 
controlRoleUser readwrite create javax.management.monitor.*,javax.management.timer.* unregister

jmxremote.password

monitorRoleUser  Pass-123-root-1
controlRoleUser  pass-123-root-2

修改jmxremote.password文件权限为600

chmod 600 jmxremote.password

修改启动文件

修改启动文件bin/kafka-run-class.sh

找到181行 - 189行，内容如下：

# JMX settings
if [ -z "$KAFKA_JMX_OPTS" ]; then
  KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false  -Dcom.sun.management.jmxremote.ssl=false "
fi

# JMX port to use
if [  $JMX_PORT ]; then
  KAFKA_JMX_OPTS="$KAFKA_JMX_OPTS -Dcom.sun.management.jmxremote.port=$JMX_PORT "
fi

改为

# JMX settings
if [ -z "$KAFKA_JMX_OPTS" ]; then
  KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=true  -Dcom.sun.management.jmxremote.ssl=false "
fi

# JMX port to use
if [  $JMX_PORT ]; then
  KAFKA_JMX_OPTS="$KAFKA_JMX_OPTS -Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.authenticate=true -Dcom.sun.management.jmxremote.port=$JMX_PORT -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.access.file=/home/xiaozhongcheng/kafka/jmxremote.access -Dcom.sun.management.jmxremote.password.file=/home/xiaozhongcheng/kafka/jmxremote.password"
fi

注意修改com.sun.management.jmxremote.access.file和com.sun.management.jmxremote.password.file为你具体的文件路径。

重启kafka。

访问kafka JMX

现在访问kafka JMX端口需要设置账号密码，账号密码为jmxremoe.password内容

monitorRoleUser  Pass-123-root-1
controlRoleUser  pass-123-root-2