获取Kafka Topic列表报ZK连接错误

小咪咪 2024-04-03 10:32 29阅读 0赞

详细错误如下，解决方法也很简单.... ZK的端口压根不是9092，默认是2181，之所以写成9092是因为之前直接拷贝的命令，9092用于bootstrap-server获取consumer信息使用的。

cd /usr/local/service/kafka
    ./bin/kafka-topics.sh --zookeeper 192.168.124.54:9092,192.168.124.25:9092,192.168.124.37:9092,192.168.124.102:9092 --list
    [2022-10-09 09:38:05,817] WARN Client session timed out, have not heard from server in 7511ms for sessionid 0x0 (org.apache.zookeeper.ClientCnxn)
    [2022-10-09 09:38:13,691] WARN Client session timed out, have not heard from server in 7507ms for sessionid 0x0 (org.apache.zookeeper.ClientCnxn)
    [2022-10-09 09:38:22,043] WARN Client session timed out, have not heard from server in 7513ms for sessionid 0x0 (org.apache.zookeeper.ClientCnxn)
    Exception in thread "main" kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
            at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$3(ZooKeeperClient.scala:225)
            at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
            at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:250)
            at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:221)
            at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:95)
            at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1548)
            at kafka.admin.TopicCommand$.main(TopicCommand.scala:57)
            at kafka.admin.TopicCommand.main(TopicCommand.scala)

发表评论取消回复

表情：

评论列表（有 0 条评论，29人围观）

还没有评论，来说两句吧...

相关阅读

相关 kafka删除topic

1. 首先需要在config/server.properties中添加 delete.topic.enable=true 属性 2. 用topic list找到想要删除的to

曾经终败给现在/ 2024年04月03日 10:33/ 0 赞/ 134 阅读

相关获取Kafka Topic列表报ZK连接错误

详细错误如下，解决方法也很简单.... ZK的端口压根不是9092，默认是2181，之所以写成9092是因为之前直接拷贝的命令，9092用于bootstrap-server获取

小咪咪/ 2024年04月03日 10:32/ 0 赞/ 30 阅读

相关 kafka删除topic时出现Error while executing topic command : Topic helloword does not exist on ZK path local

截图事例：先查看topic： ![在这里插入图片描述][20191125091352735.png] HelloWor、HelloWorld、test。这三个是我

悠悠/ 2023年06月16日 07:48/ 0 赞/ 10 阅读

相关 kafka describe topic

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5a2m5Lqu57yW5

红太狼/ 2022年09月11日 06:20/ 0 赞/ 50 阅读

相关 kafka删除topic

运行./kafka-topics.sh -delete -zookeeper \[zookeeper server\] -topic \[topic name\]；如果kafk

不念不忘少年蓝@/ 2022年05月28日 03:07/ 0 赞/ 322 阅读

相关 Kafka如何获取topic最近n条消息

问题来源项目运行中我们经常需要诊断个个环节是否正确，其中到kafka就需要查看最新的消息到达kafka没有，达到的内容是什么，这就需要查看kafka指定topic的最近

刺骨的言语ヽ痛彻心扉/ 2022年03月25日 10:40/ 0 赞/ 823 阅读

相关 Kafka 删除topic

删除topic里面的数据这里没有单独的清空数据的命令，这里要达到清空数据的目的只需要以下步骤：一、如果当前topic没有使用过即没有传输过信息：可以彻底删除。二

桃扇骨/ 2022年02月26日 10:26/ 0 赞/ 380 阅读

相关 kafka删除topic数据

[kafka删除topic数据][kafka_topic] 一、概述生产环境中，有一个topic的数据量非常大。这些数据不是非常重要，需要定期清理。要求：默认

╰半橙微兮°/ 2022年02月02日 08:51/ 0 赞/ 489 阅读

相关 kafka删除一个topic

前言当我们在shell中执行topic删除命令的时候\` kafka-topics --delete --topic xxxx --zookeeper xxx\`，会显

﹏ヽ暗。殇╰゛Y/ 2021年12月22日 23:47/ 0 赞/ 388 阅读

相关 Kafka删除Topic

CDH平台勾选 delete.topics.enable 重启Kafka，否则Topic会标记为marked for deletion，重启才会真正删除。取消

曾经终败给现在/ 2021年09月23日 06:48/ 0 赞/ 465 阅读