相关疑难解决方法(0)

Kafka Broker 找不到集群 ID 并在 docker 重启后创建新的集群 ID

我已经使用 kafka 代理和动物园管理员创建了 docker 以使用运行脚本启动它。如果我重新启动,它会正常启动并运行正常(Windows -> WSL -> 两个 tmux 窗口,一个会话)。如果我关闭 kafka 或 zookeeper 并重新启动它,它将正常连接。

当我停止 docker 容器(docker stop my_kafka_container)时出现问题。然后我从我的脚本 ./run_docker 开始。在开始之前的那个脚本中,我删除旧容器docker rm my_kafka_container,然后 docker run。

Zookeeper 正常启动,并且在文件 meta.properties 中,它具有上次启动时的旧集群 ID,但 kafka 代理由于某种原因无法通过 znode cluster/id 找到此 id 并创建新的,这不是存储在 meta.properties 中的。我得到

  ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID m1Ze6AjGRwqarkcxJscgyQ doesn't match stored clusterId Some(1TGYcbFuRXa4Lqojs4B9Hw) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.
        at kafka.server.KafkaServer.startup(KafkaServer.scala:220) …
Run Code Online (Sandbox Code Playgroud)

apache-kafka docker apache-zookeeper

15
推荐指数
6
解决办法
2万
查看次数

标签 统计

apache-kafka ×1

apache-zookeeper ×1

docker ×1