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一个小问题相关推荐

  1. UG12.0出现验证码错误处理方法,同时附赠一个小细节UG安装出现用户名中文的情况的,希望你能别去花钱重装哦

    标题:UG12.0出现验证码错误处理方法,同时附赠一个小细节UG安装出现用户名中文的情况的,希望你能别去花钱重装哦 亲测有效 先找到这个文件夹,安装在一个盘里 把第一个文件里的内容删除掉,第二个打开后 ...

  2. 【Java常识】10.0 基本数据类型的自动装箱、拆箱、正则表达式

    1.0 基本数据类型有专门的包,这算是很常识了.但是有个小知识点,就是涉及自动装箱拆箱. 代码演示如下: package edp.com.learn1;public class Demo {publi ...

  3. Kafka集群安装Version1.0.1(自带Zookeeper)

    1.说明 Kafka集群安装,基于版本1.0.1, 使用kafka_2.12-1.0.1.tgz安装包, 其中2.12是编译工具Scala的版本. 而且不需要另外安装Zookeeper服务, 使用Ka ...

  4. java 10.0.2 配置 bcprov-jdk-15

    长话短说,java 更新到 10.0.2 了 ,没有了以前的 /jdk/lib/ext 目录. 不过,还有一种方法就是Project Structure 直接配置,后边就不说了.

  5. kafka Java客户端之 consumer API 多线程消费消息

    kafka consumer 线程设计 Kafka Java Consumer采用的是单线程的设计.其入口类KafkaConsumer是一个双线程的设计,即用户主线程和心跳线程. 用户主线程,指的是启 ...

  6. OpenKruise v0.10.0 版本发布:新增应用弹性拓扑管理、应用防护等能力

    简介:阿里云开源的云原生应用自动化管理套件.CNCF Sandbox 项目 -- OpenKruise,今天发布 v0.10.0 新版本,这也会是 OpenKruise v1.0 之前的最后一个 mi ...

  7. 关于storm0.10.0版本的一个小bug

    最近搭建了一个storm环境,发现在提交一个topology之后,supervisor总是会无缘无故的死掉,日志如下 [2000] the maxSleepTimeMs [60000] the max ...

  8. 不用科学梯子下载mokee-mkq-mr1分支安卓10.0源码

    之前已经安装过repo,下载过 mkp 分支 9.0源码,在这样的情况下继续下载 mkq-mr1分支 10.0源码    1.在合适的位置创建目标目录moke-mkq-mr1, 2.执行install ...

  9. OpenShift 容器平台社区版 OKD 4.10.0部署--基于VSphere

    参考:OpenShift 容器平台社区版 OKD 4.10.0部署 OpenShift - 部署 OKD 4.5_51CTO博客_openshift 部署 一.Openshift简介 RedHat O ...

最新文章

  1. 《电子基础与维修工具核心教程》——2.6 节点分压原理
  2. 在windows下使用putty登陆linux
  3. 跟小段一起学Solaris(20)---ipFilter防火墙
  4. Nexus for linux安装
  5. 饿了么风神登录_海底捞首度登陆第三方外卖!联手饿了么全国配送“小火锅”...
  6. Android 系统(140)---android.mk中几个常见配置
  7. uat测试用例怎么写_你会写测试用例吗
  8. button执行onclick函数_JavaScript 函数定义与调用
  9. Linux系统配置jdk
  10. mybatis基础入门
  11. IO字节流读取文本中文乱码
  12. Vim 插件管理工具 pathogen
  13. 三维开发及三维地形和地理信息系统的集成探索
  14. java基于ssm+jsp的抑郁症心理健康科普交流网站
  15. 接上个文章(mzsock
  16. upupoo启动不了 mysql_显示桌面快捷方式
  17. 写了个自动批改小孩作业的代码~
  18. 嵌入式系统之-小米路由器3G v1
  19. app被Rejected 的各种原因翻译
  20. 计算机应用对字数的要求,信息系统项目管理师考试论文字数要求是多少,没达标会扣多少分...

热门文章

  1. Dubbo:Spring Cloud 服务调用的新选择
  2. cheat.sh 在手,天下我有
  3. 用树莓派打造世界上最小的“iMac”
  4. 每日一皮:第一次用CSS的时候,我震惊了...
  5. 实战派:一次kafka卡顿事故排查过程!
  6. 如何避免死锁,我们有什么套路可循?
  7. 你的微服务实践还顺利吗?
  8. 你想学习Java ?资源都在这里了
  9. zbg是什么意思_zbg的含义,zbg是什么的缩写,zbg的词语,zbg代表的意思
  10. 百度小程序opencard书法字典名家书法等测试日志记录