kafka java创建topic_kafkakafka_2.10-0.8.2.1+zookeeper-3.4.6 创建topic一个小问题
kafka 创建topic时出现如下异常:
Error while executing topic command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685)
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413)
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409)
at kafka.utils.ZkUtils$.getChildren(ZkUtils.scala:462)
at kafka.utils.ZkUtils$.getSortedBrokerList(ZkUtils.scala:78)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:170)
at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:55)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500)
at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99)
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416)
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
... 8 more
在之前的版本中一直没有这样问题,当kafka安装成功时通过集群查看一切都是正常的,但是创建topic确始终提示找不到节点,一开始是用如下命令创建的,这是照 前文档和其它资料做的:
kafka-topics.sh --create --topic firsttopic --replication-factor 2 --partitions 2 --zookeeper slave1:2181 用这个命令始报上述异常。最后试着把他zookeeper集群全路径写上,结果就成功创建了,用如下命令:
kafka-topics.sh --create --topic firsttopic --replication-factor 2 --partitions 2 --zookeeper slave1:2181/kafka
kafka java创建topic_kafkakafka_2.10-0.8.2.1+zookeeper-3.4.6 创建topic一个小问题相关推荐
- UG12.0出现验证码错误处理方法,同时附赠一个小细节UG安装出现用户名中文的情况的,希望你能别去花钱重装哦
标题:UG12.0出现验证码错误处理方法,同时附赠一个小细节UG安装出现用户名中文的情况的,希望你能别去花钱重装哦 亲测有效 先找到这个文件夹,安装在一个盘里 把第一个文件里的内容删除掉,第二个打开后 ...
- 【Java常识】10.0 基本数据类型的自动装箱、拆箱、正则表达式
1.0 基本数据类型有专门的包,这算是很常识了.但是有个小知识点,就是涉及自动装箱拆箱. 代码演示如下: package edp.com.learn1;public class Demo {publi ...
- Kafka集群安装Version1.0.1(自带Zookeeper)
1.说明 Kafka集群安装,基于版本1.0.1, 使用kafka_2.12-1.0.1.tgz安装包, 其中2.12是编译工具Scala的版本. 而且不需要另外安装Zookeeper服务, 使用Ka ...
- java 10.0.2 配置 bcprov-jdk-15
长话短说,java 更新到 10.0.2 了 ,没有了以前的 /jdk/lib/ext 目录. 不过,还有一种方法就是Project Structure 直接配置,后边就不说了.
- kafka Java客户端之 consumer API 多线程消费消息
kafka consumer 线程设计 Kafka Java Consumer采用的是单线程的设计.其入口类KafkaConsumer是一个双线程的设计,即用户主线程和心跳线程. 用户主线程,指的是启 ...
- OpenKruise v0.10.0 版本发布:新增应用弹性拓扑管理、应用防护等能力
简介:阿里云开源的云原生应用自动化管理套件.CNCF Sandbox 项目 -- OpenKruise,今天发布 v0.10.0 新版本,这也会是 OpenKruise v1.0 之前的最后一个 mi ...
- 关于storm0.10.0版本的一个小bug
最近搭建了一个storm环境,发现在提交一个topology之后,supervisor总是会无缘无故的死掉,日志如下 [2000] the maxSleepTimeMs [60000] the max ...
- 不用科学梯子下载mokee-mkq-mr1分支安卓10.0源码
之前已经安装过repo,下载过 mkp 分支 9.0源码,在这样的情况下继续下载 mkq-mr1分支 10.0源码 1.在合适的位置创建目标目录moke-mkq-mr1, 2.执行install ...
- OpenShift 容器平台社区版 OKD 4.10.0部署--基于VSphere
参考:OpenShift 容器平台社区版 OKD 4.10.0部署 OpenShift - 部署 OKD 4.5_51CTO博客_openshift 部署 一.Openshift简介 RedHat O ...
最新文章
- 《电子基础与维修工具核心教程》——2.6 节点分压原理
- 在windows下使用putty登陆linux
- 跟小段一起学Solaris(20)---ipFilter防火墙
- Nexus for linux安装
- 饿了么风神登录_海底捞首度登陆第三方外卖!联手饿了么全国配送“小火锅”...
- Android 系统(140)---android.mk中几个常见配置
- uat测试用例怎么写_你会写测试用例吗
- button执行onclick函数_JavaScript 函数定义与调用
- Linux系统配置jdk
- mybatis基础入门
- IO字节流读取文本中文乱码
- Vim 插件管理工具 pathogen
- 三维开发及三维地形和地理信息系统的集成探索
- java基于ssm+jsp的抑郁症心理健康科普交流网站
- 接上个文章(mzsock
- upupoo启动不了 mysql_显示桌面快捷方式
- 写了个自动批改小孩作业的代码~
- 嵌入式系统之-小米路由器3G v1
- app被Rejected 的各种原因翻译
- 计算机应用对字数的要求,信息系统项目管理师考试论文字数要求是多少,没达标会扣多少分...