kafka.common.InconsistentClusterIdException

kafka错误日志

[2022-06-06 11:36:25,140] INFO Client environment:os.memory.total=4096MB (org.apache.zookeeper.ZooKeeper)
[2022-06-06 11:36:25,142] INFO Initiating client connection, connectString=zcbuszookeeper:2181 sessionTimeout=400000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@3d51f06e (org.apache.zookeeper.ZooKeeper)
[2022-06-06 11:36:25,147] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2022-06-06 11:36:25,152] INFO jute.maxbuffer value is 4194304 Bytes (org.apache.zookeeper.ClientCnxnSocket)
[2022-06-06 11:36:25,157] INFO zookeeper.request.timeout value is 0. feature enabled= (org.apache.zookeeper.ClientCnxn)
[2022-06-06 11:36:25,160] INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient)
[2022-06-06 11:36:25,171] INFO Opening socket connection to server zcbuszookeeper/172.18.0.6:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
[2022-06-06 11:36:25,180] INFO Socket connection established, initiating session, client: /172.18.0.7:59844, server: zcbuszookeeper/172.18.0.6:2181 (org.apache.zookeeper.ClientCnxn)
[2022-06-06 11:36:25,189] INFO Session establishment complete on server zcbuszookeeper/172.18.0.6:2181, sessionid = 0x101825b983c0007, negotiated timeout = 240000 (org.apache.zookeeper.ClientCnxn)
[2022-06-06 11:36:25,197] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient)
[2022-06-06 11:36:25,522] INFO Cluster ID = lsoHesqkTeClqkZEZxES-g (kafka.server.KafkaServer)
[2022-06-06 11:36:25,533] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID lsoHesqkTeClqkZEZxES-g doesn't match stored clusterId Some(Nsdnrkl_QVGHWOYTJlr5mA) 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)
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
    at kafka.Kafka$.main(Kafka.scala:84)
    at kafka.Kafka.main(Kafka.scala)
[2022-06-06 11:36:25,535] INFO shutting down (kafka.server.KafkaServer)
[2022-06-06 11:36:25,538] INFO [ZooKeeperClient Kafka server] Closing. (kafka.zookeeper.ZooKeeperClient)
[2022-06-06 11:36:25,646] INFO Session: 0x101825b983c0007 closed (org.apache.zookeeper.ZooKeeper)
[2022-06-06 11:36:25,646] INFO EventThread shut down for session: 0x101825b983c0007 (org.apache.zookeeper.ClientCnxn)
[2022-06-06 11:36:25,648] INFO [ZooKeeperClient Kafka server] Closed. (kafka.zookeeper.ZooKeeperClient)
[2022-06-06 11:36:25,651] INFO shut down completed (kafka.server.KafkaServer)
[2022-06-06 11:36:25,651] ERROR Exiting Kafka. (kafka.server.KafkaServerStartable)
[2022-06-06 11:36:25,654] INFO shutting down (kafka.server.KafkaServer)

解决办法:

注意两点：
1、log.dirs配置的路径要正确
2、删除这里面的meta.properties文件

重启zcbuszookeeper
重启zcbuskafka