kafka manager遇到的一些问题
1.启动后第一个报错如下:
[error] k.m.a.c.BrokerViewCacheActor - Failed to get broker metrics for BrokerIdentity(1,192.168.204.111,9999,false,true,Map(PLAINTEXT -> 9092))
java.rmi.ConnectException: Connection refused to host: 127.0.0.1; nested exception is:
修改方法:
修改kafka-server-start.sh
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
export JMX_PORT="9999"
fi
增加红色部分,指定jmx
的端口
同时修改kafka-run-class.sh
# JMX settings
if [ -z "$KAFKA_JMX_OPTS" ]; then
KAFKA_JMX_OPTS="-Djava.rmi.server.hostname=192.168.204.108 -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false "
fi
增加红色部分。
2.第二个报错
java.io.IOException: Failed to retrieve RMIServer stub: javax.naming.CommunicationException [Root exception is java.rmi.ConnectIOException: error during JRMP connection establishment; nested exception is:
解决方法:
不要开启JMX with SSL功能。
最新文章
- 创建第一个 vlan network ";vlan100"; - 每天5分钟玩转 OpenStack(94)
- GNU make使用变量⑤变量的引用、定义等
- T-SQL编程 —— 用户自定义函数(标量函数)
- Mybatis 3.3.0 Log4j配置
- SQL Server数据库ROW_NUMBER()函数使用详解
- linux系统
- ZZC语言代码风格
- Codeforces Round #338 (Div. 2) B. Longtail Hedgehog dp
- lnmp停用nginx,改用apache
- or1200下raw-os(仿真环境篇)
- linux中文设置
- Bash常用快捷键
- 如何实现Web聊天
- NUMBER_GET_NEXT 获取编号 遇到关于按年度编号的问题
- python 密码学编程
- php操作Memcache的一个类库
- CentOS7 PHP+Redis实现Session共享
- notepad 正则表达式 复制 文本
- substr、substring和slice的区别
- C# WINFORM 打包数据库