[2023-02-07 11:12:14,604] INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient)

[2023-02-07 11:12:14,886] INFO [feature-zk-node-event-process-thread]: Starting (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)

[2023-02-07 11:12:14,901] INFO Feature ZK node at path: /feature does not exist (kafka.server.FinalizedFeatureChangeListener)

[2023-02-07 11:12:14,902] INFO Cleared cache (kafka.server.FinalizedFeatureCache)

[2023-02-07 11:12:15,214] INFO Cluster ID = ewSqnt5STMCtZImrKWHq-A (kafka.server.KafkaServer)

[2023-02-07 11:12:15,232] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)

kafka.common.InconsistentClusterIdException: The Cluster ID ewSqnt5STMCtZImrKWHq-A doesn't match stored clusterId Some(LCvquFCbRXi2n8P97femcQ) 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:223)

at kafka.Kafka$.main(Kafka.scala:109)

at kafka.Kafka.main(Kafka.scala)

[2023-02-07 11:12:15,236] INFO shutting down (kafka.server.KafkaServer)

[2023-02-07 11:12:15,243] INFO [feature-zk-node-event-process-thread]: Shutting down (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)

[2023-02-07 11:12:15,256] INFO [feature-zk-node-event-process-thread]: Stopped (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)

[2023-02-07 11:12:15,256] INFO [feature-zk-node-event-process-thread]: Shutdown completed (kafka.server.FinalizedFeatureChangeListener$ChangeNotificationProcessorThread)

[2023-02-07 11:12:15,258] INFO [ZooKeeperClient Kafka server] Closing. (kafka.zookeeper.ZooKeeperClient)

[2023-02-07 11:12:15,388] INFO Session: 0x200009146620000 closed (org.apache.zookeeper.ZooKeeper)

[2023-02-07 11:12:15,389] INFO EventThread shut down for session: 0x200009146620000 (org.apache.zookeeper.ClientCnxn)

[2023-02-07 11:12:15,390] INFO [ZooKeeperClient Kafka server] Closed. (kafka.zookeeper.ZooKeeperClient)

[2023-02-07 11:12:15,397] INFO App info kafka.server for 0 unregistered (org.apache.kafka.common.utils.AppInfoParser)

[2023-02-07 11:12:15,399] INFO shut down completed (kafka.server.KafkaServer)

[2023-02-07 11:12:15,400] ERROR Exiting Kafka. (kafka.Kafka$)

[2023-02-07 11:12:15,401] INFO shutting down (kafka.server.KafkaServer)

kakfa

[al@hadoop101 kafka]$ ll

总用量 72

drwxr-xr-x. 3 al al 4096 9月 9 2021 bin

drwxr-xr-x. 3 al al 4096 2月 7 11:21 config

drwxrwxr-x. 2 al al 4096 2月 6 23:29 datas

drwxr-xr-x. 2 al al 4096 2月 6 23:17 libs

-rw-r--r--. 1 al al 14521 9月 9 2021 LICENSE

drwxr-xr-x. 2 al al 4096 9月 9 2021 licenses

drwxrwxr-x. 2 al al 4096 2月 7 11:01 logs

-rw-r--r--. 1 al al 28184 9月 9 2021 NOTICE

drwxr-xr-x. 2 al al 4096 9月 9 2021 site-docs

[al@hadoop101 datas]$ ll

总用量 12

-rw-rw-r--. 1 al al 0 2月 6 23:27 cleaner-offset-checkpoint

-rw-rw-r--. 1 al al 4 2月 6 23:29 log-start-offset-checkpoint

-rw-rw-r--. 1 al al 88 2月 6 23:27 meta.properties

-rw-rw-r--. 1 al al 4 2月 6 23:29 recovery-point-offset-checkpoint

-rw-rw-r--. 1 al al 0 2月 6 23:27 replication-offset-checkpoint

删掉datas 和logs目录

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐