博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Kafka 监控
阅读量:4205 次
发布时间:2019-05-26

本文共 2241 字,大约阅读时间需要 7 分钟。

监控

主流开源监控

Kafka Web Conslole

Kafka Manager

KafkaOffsetMonitor

错误汇总

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/

你可能感兴趣的文章