Kafka中操作topic时 Error:Failed to parse the broker info from zookeeper
2024-10-12 20:28:57
Kafka中操作topic时 Error: Failed to parse the broker info from zookeeper
1.问题描述
2.问题原因
kafka在启动后,会将broker的信息存放在对应的zookeeper里的zNode中,默认存放在zookeeper中的路径 /broker/ids/xxx(当然如果在kafka的server.properties文件中指定zookeeper中的路径/kafka,那么对应的zNode也会在/kafka下创建)
当出现不能从zookeeper中解析broker的信息时,那么就是说明zookeeper中没有对应的zNode(/broker/ids/xxx)或者有这个zNode(即ids下的broker id)但是broker id中没有该broker的信息
For example:
方式一(以下在kafka的server.properties中指定了/kafka,那么会在zookeeper的/kafka路径下创建/broker/ids/xxx)
1.这是在server.properties的配置
2.在zookeeper中查看对应的zNode
方式二(以下在kafka的server.properties中没有指定/kafka,那么默认的路径是在zookeeper的根路径下创建/broker/ids/xxx)
1.这是在server.properties的配置
2.在zookeeper中查看对应的zNode
3.解决方案
方案一:
重新启动kafka集群
方案二:
首先知道kafka集群依赖的zookeeper的集群以及zookeeper的安装目录;
其次知道kafka集群的broker有那几台(就是每一个broker的broker id是多少),同时查看kafka配置文件server.properties中连接zookeeper时有没有指定路径(比如/kafka)
然后进入到$ZOOKEEPER_HOME/bin下启动zkCli.sh,如果么有对应的zNode,那么创建(注意是在根路径下还是在/kafka下),然后在每一个zNode(/broker/ids/broker的id)下放入该broker的信息
在zookeeper上创建broker信息(date -d @1504856535 +"%Y-%m-%d %H:%M:%S")
set /brokers/ids/182 {"jmx_port":-1,"timestamp":"1504856535","endpoints":["PLAINTEXT://123.59.18.182:9092"],"host":"123.59.18.182","version":1,"port":9092}
set /brokers/ids/183 {"jmx_port":-1,"timestamp":"1504856535","endpoints":["PLAINTEXT://123.59.18.183:9092"],"host":"123.59.18.183","version":1,"port":9092}
set /brokers/ids/154 {"jmx_port":-1,"timestamp":"1504856535","endpoints":["PLAINTEXT://123.59.18.154:9092"],"host":"123.59.18.154","version":1,"port":9092}
set /brokers/ids/33 {"jmx_port":-1,"timestamp":"1504856535","endpoints":["PLAINTEXT://123.59.17.33:9092"],"host":"123.59.17.33","version":1,"port":9092}
set /brokers/ids/116 {"jmx_port":-1,"timestamp":"1504856535","endpoints":["PLAINTEXT://123.59.17.116:9092"],"host":"123.59.17.116","version":1,"port":9092}
最后创建topic,执行成功
最新文章
- online_jf.lua --累计在线时间领取物品(积分)的lua脚本
- oracle 字符转字符串函数
- 我的c漏洞
- Classes
- React Native填坑之旅--动画
- php基础09:提取表单数据
- js完美解决IE6不支持position:fixed的bug
- Apache支持.htaccess配置方法
- 关于fixed-point
- Hibernate 性能优化之查询缓存
- Extjs4 操作TreeStore 处理proxyAjax 获取的数据
- Win下JDK的安装和简单使用教程
- ActionMode 就记这么一点,不能更多了
- Insert Sort Singly List
- 【转】DELL R710服务器可以安装的VMWare ESX Server 4.1 全套下载带注册码
- 全球性WannaCry蠕虫勒索病毒感染前后应对措施
- idea中Springcloud同时运行多个模块、微服务
- _C#发送邮箱
- Django的POST请求时因为开启防止csrf,报403错误,及四种解决方法
- layer.js 中弹框显示不全的问题