本文共 2241 字,大约阅读时间需要 7 分钟。
Exception in thread "Timer-0" org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers 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:480) at com.quantifind.kafka.OffsetGetter.getGroups(OffsetGetter.scala:128) at com.quantifind.kafka.offsetapp.OffsetGetterWeb$$anonfun$getGroups$1.apply(OffsetGetterWeb.scala:99) at com.quantifind.kafka.offsetapp.OffsetGetterWeb$$anonfun$getGroups$1.apply(OffsetGetterWeb.scala:99) at com.quantifind.kafka.offsetapp.OffsetGetterWeb$.getGroups(OffsetGetterWeb.scala:98) at com.quantifind.kafka.offsetapp.OffsetGetterWeb$.writeToDb(OffsetGetterWeb.scala:44) at com.quantifind.kafka.offsetapp.OffsetGetterWeb$$anon$2.run(OffsetGetterWeb.scala:56) at java.util.TimerThread.mainLoop(Unknown Source) at java.util.TimerThread.run(Unknown Source)Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers at org.apache.zookeeper.KeeperException.create(KeeperException.java:102) at org.apache.zookeeper.KeeperException.create(KeeperException.java:42) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1249) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1277) 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)
原因,因为我的Kafka没有布到root下,而是在/td-kafka-gw下。
办法:启动命令中–zk参数改为》–zk ip:port,ip:port,ip:port/td-kafka-gw。转载地址:http://vytli.baihongyu.com/