我已经使用 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)