“kafka.zookeeper.ZooKeeperClientTimeoutException:等待连接超时”仅在列出主题期间

2023-11-24

我发现了一些主题相似但上下文不同的问题:我可以连接以创建主题,但无法列出主题,因为我收到了下面提到的错误(据我所知,人们在我时面临基本连接问题)我只是为了列出主题列表)。

如果重要的话,这是我的docker-compose.yml:

version: "3"
services:
    zookeeper:
        image: wurstmeister/zookeeper

    kafka:
        image: wurstmeister/kafka
        ports:
            - "9092:9092"
        environment:
            KAFKA_ADVERTISED_HOST_NAME: "localhost"
            KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181"

我的控制台:

bash-4.4# kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test2
Created topic test2.
bash-4.4# kafka-topics.sh --list --zookeeper localhost:2181
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:259)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:253)
        at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:255)
        at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:113)
        at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1858)
        at kafka.admin.TopicCommand$ZookeeperTopicService$.apply(TopicCommand.scala:321)
        at kafka.admin.TopicCommand$.main(TopicCommand.scala:54)
        at kafka.admin.TopicCommand.main(TopicCommand.scala)

bash-4.4# kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test3
Created topic test3.
bash-4.4# kafka-topics.sh --list --zookeeper localhost:2181
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:259)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:253)
        at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:255)
        at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:113)
        at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1858)
        at kafka.admin.TopicCommand$ZookeeperTopicService$.apply(TopicCommand.scala:321)
        at kafka.admin.TopicCommand$.main(TopicCommand.scala:54)
        at kafka.admin.TopicCommand.main(TopicCommand.scala)

Edited

未来的读者可能会发现,如何直接从 Docker Kafka 容器列出所有主题,而无需登录 Docker Zookeper 容器(https://stackoverflow.com/a/56595227/4148175)

C:\Users\>docker exec -it test1_kafka_1 bash

bash-4.4# kafka-topics.sh --list --bootstrap-server localhost:9092
__consumer_offsets
test2
test3
test_topic
bash-4.4# 

--zookeeper zookeeper:2181似乎效果很好

--zookeeper localhost:2181在kafka容器内总是会失败,因为它没有运行zookeeper服务器


我可以直接从 Docker Kafka 容器列出所有主题,而无需登录 Docker Zookeper 容器

这是正确的。理想情况下,您永远不应该进入 Zookeeper 容器。最新的kafka版本支持使用--bootstrap-server instead,所以你可以使用kafka:9092 or localhost:9092来自卡夫卡容器

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

“kafka.zookeeper.ZooKeeperClientTimeoutException:等待连接超时”仅在列出主题期间 的相关文章

随机推荐

  • 如何确保 Rails API 免受 CSRF 的保护?

    我一直在使用 REST API 开发 Rails 应用程序 以便从移动应用程序进行访问 它运作得很好 当用户从移动应用程序登录时 他会得到auth token他在将来的 API 请求中使用它 问题是 API 也可以通过路径 api v1 从
  • python - 创建数据透视表

    我正在尝试从 python 中的 Numpy 数组创建数据透视表 我做了很多研究 但找不到直接的解决方案 我知道你可以用 Pandas 来做到这一点 但我在安装它时遇到了麻烦 但一定有一种方法可以在没有 Pandas 的情况下做到这一点 我
  • cakephp 在数据源默认值中找不到模型表

    我的数据库中只有一个名为 ficha seg 的表 我的模型文件的名称是 Ficha php 控制器的名称是 FichasController php 那么 为什么我收到错误 Error Table fichas for model Fic
  • 使用指针迭代 argv[]

    我想使用以下代码 但不使用 索引数组并用指针替换它 for int i 0 i lt argc i for int j 0 argv i j 0 j code 我知道您可以使用指针来遍历数组 但我不确定如何使用第二个数组中未定义的长度 在本
  • Spark MLLib Kmeans 来自数据帧,然后再次返回

    我的目标是使用 Spark 1 3 1 MLLib 将 kmeans 聚类算法应用于非常大的数据集 我已经使用 Spark 中的 hiveContext 调用了 HDFS 中的数据 并且最终希望以这种方式将其放回原处 以这种格式 I D c
  • 获取 Qt Widget 的变量名称(用于样式表)?

    在我的应用程序中 用户单击程序的任何小部件 当时处于休眠状态 并为其选择颜色 然后 该颜色将被添加到该特定小部件的样式表中 但是 当程序结束并再次启动时 我希望该特定小部件保留其样式表 我不想在每个小部件的样式表中进行硬编码 事实上 我什至
  • 带有 Tesseract 的空字符串

    我正在尝试从一个大文件中读取不同的裁剪图像 并且我设法读取了其中的大部分图像 但是当我尝试使用超正方体读取它们时 其中一些图像会返回空字符串 代码就是这一行 pytesseract image to string cv2 imread im
  • 如何查看从给定文件开始的完整节点“require()”树?

    我需要查看某种依赖关系树 显示各种require 从特定文件开始 例如 如果我有一个server js像这样的文件 server js var myThing require myThing and a myThing js像这样的文件 m
  • 如何在 JavaScript 中从二进制数据创建 File 对象

    我可能在这里遗漏了一些简单的东西 但是如果给定从 AJAX 请求接收到的二进制数据 我如何在 JavaScript 中创建一个 File 对象呢 ajax url http example com image jpg success fun
  • 如何为图像创建三角形容器(x-浏览器)

    我将如何创建一个包含 IMG 的 DIV 其中 DIV 将图像切割成三角形 从而通过三角形仅显示图像的一部分 so div img src some image div 其中图像是正方形 但包含图像的 DIV 是三角形 http www s
  • 使用 Array.forEach 迭代 getElementsByClassName 的结果

    我想迭代一些 DOM 元素 我这样做 document getElementsByClassName myclass forEach function element index array do stuff 但我收到错误 document
  • 在 Safari 中禁用同源策略

    出于开发目的 我需要在我的计算机上的 Safari Windows 上 中禁用同源策略 在 Chrome 中 这可以通过使用标志启动来完成 disable web security Safari 中是否有等效的标志或隐藏设置 如果你想在Sa
  • 当我的 NodeJS 应用程序在我的计算机上运行时,本地网络上的其他人如何访问它?

    我有一个非常简单的问题 我用NodeJS做了一个网页游戏 我可以在并排打开多个浏览器窗口的情况下自己成功玩它 但是 我想知道其他本地计算机是否也可以访问并与我一起玩游戏 我天真地尝试使用这个网址 my ip address 8000这是行不
  • 在 Ruby 1.8 中将字符串简单转换为 UTF-8

    我知道在 Ruby 1 9 中你可以轻松地重新编码这样的字符串 s s encode UTF 8 Ruby 1 8 中的等效项是什么 它需要什么线路 我见过的所有教程都不必要地复杂 我不明白发生了什么 詹姆斯 爱德华 格雷二世有一个详细帖子
  • CRC16 ISO 13239 实施

    我正在尝试在 C 中实现 Crc16 我已经尝试了许多不同的实现 但大多数都给了我不同的值 这是我已经使用过的一些代码 private static int POLYNOMIAL 0x8408 private static int PRES
  • 无法选择 MKViewAnnotation 两次?

    我在地图上放置了图钉 当我点击它们时 我会调用didSelect 该函数仅在第一次点击该引脚时被调用 之后不会再次在同一引脚上调用该函数 除非我选择另一个引脚然后返回并点击它 对我来说 这听起来像是正在选择引脚 并且didSelect只能在
  • 我应该在哪里放置 Junit @Category 的接口类?

    我想定义项目范围的接口 用于 Category注释 并配置 Maven 在构建整个项目时排除其注释测试 In the 应用项目中有一个测试我想分类 Category Integration class Test public void te
  • Django 无法切换语言环境

    我有文件 locale es LC MESSAGES django mo 和 po 运行 makemessages 和compilemessages 绝对所有消息都已翻译 在settings py中有 USE I18N True LANGU
  • Laravel 中的位置标头

    我正在为我的大学的身份验证系统 Ucam Webauth 使用图书馆 这意味着我必须使用其中一种方法重定向到身份验证服务器 不幸的是 我无法退货Redirect to 因为这个图书馆的架构 图书馆本身使用header Location 但这
  • “kafka.zookeeper.ZooKeeperClientTimeoutException:等待连接超时”仅在列出主题期间

    我发现了一些主题相似但上下文不同的问题 我可以连接以创建主题 但无法列出主题 因为我收到了下面提到的错误 据我所知 人们在我时面临基本连接问题 我只是为了列出主题列表 如果重要的话 这是我的docker compose yml versio