CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.
[2022-12-09 07:55:54,663] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient)
[2022-12-09 07:55:56,188] INFO Cluster ID = TSEPCOBgTWiL9AEHhLmQ1g (kafka.server.KafkaServer)
[2022-12-09 07:55:56,224] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID TSEPCOBgTWiL9AEHhLmQ1g doesn't match stored clusterId Some(SuTu3wnsSiyPOayrKvZVMg) 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:224)
at kafka.Kafka$.main(Kafka.scala:109)
at kafka.Kafka.main(Kafka.scala)
[2022-12-09 07:55:56,227] INFO shutting down (kafka.server.KafkaServer)
[2022-12-09 07:55:56,231] INFO [ZooKeeperClient Kafka server] Closing. (kafka.zookeeper.ZooKeeperClient)
[2022-12-09 07:55:56,374] INFO Session: 0x200030b29950000 closed (org.apache.zookeeper.ZooKeeper)
[2022-12-09 07:55:56,374] INFO EventThread shut down for session: 0x200030b29950000 (org.apache.zookeeper.ClientCnxn)
[2022-12-09 07:55:56,393] INFO [ZooKeeperClient Kafka server] Closed. (kafka.zookeeper.ZooKeeperClient)
[2022-12-09 07:55:56,409] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)
[2022-12-09 07:55:56,410] INFO shut down completed (kafka.server.KafkaServer)
[2022-12-09 07:55:56,410] ERROR Exiting Kafka due to fatal exception during startup. (kafka.Kafka$)
kafka.common.InconsistentClusterIdException: The Cluster ID TSEPCOBgTWiL9AEHhLmQ1g doesn't match stored clusterId Some(SuTu3wnsSiyPOayrKvZVMg) 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:224)
at kafka.Kafka$.main(Kafka.scala:109)
at kafka.Kafka.main(Kafka.scala)
[2022-12-09 07:55:56,417] INFO shutting down (kafka.server.KafkaServer)