JMX_PORT=12345 bin/kafka-server-start.sh -daemon config/server.properties  直接这样运行不会报错,远程可以读数据

或者改脚本配置,这样再去启动生产者啥的也不会报错。如果是改kafka-run-class.sh再去启动生产者就会报错

在启动kafka的脚本kafka-server-start.sh中找到堆设置,添加export JMX_PORT="9999"

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
export JMX_PORT="9999"
fi

 

 

 

 

直接改kafka-run-class.sh那个脚本,改完以后启动生产者会报错,说12345存在

/usr/local/kafka/bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test

Error: Exception thrown by the agent : java.rmi.server.ExportException: Port already in use: 12345; nested exception is:
java.net.BindException: Address already in use (Bind failed)

 

 

 

http://kafka.apachecn.org/documentation.html#monitoring

https://blog.csdn.net/feelwing1314/article/details/80808721   有详细的,不过用的也是run-class那种

 

https://www.cnblogs.com/songanwei/p/9203529.html

jmx端口主要用来监控kafka集群的。

在启动kafka的脚本kafka-server-start.sh中找到堆设置,添加export JMX_PORT=”9999″

if [ “x$KAFKA_HEAP_OPTS” = “x” ]; then
export KAFKA_HEAP_OPTS=”-Xmx1G -Xms1G”
export JMX_PORT=”9999″
fi
这样在kafka-manager中就不会看到出错信息了。
———————
作者:mnasd
来源:CSDN
原文:https://blog.csdn.net/mnasd/article/details/82756785
版权声明:本文为博主原创文章,转载请附上博文链接!

 

 

https://blog.csdn.net/feelwing1314/article/details/80808721

发表评论

邮箱地址不会被公开。 必填项已用*标注