window启动kafka报错:

ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID fESar1C0RH6tml3NB3N2Mw doesn't match stored clusterId Some(7DWuwcd0SgmM4PoafW2LSQ) 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:218)
        at kafka.Kafka$.main(Kafka.scala:109)
        at kafka.Kafka.main(Kafka.scala)

2、问题解决

service.properties:
1、修改zookeeper链接时间: 
zookeeper.connection.timeout.ms=60000

2、修改日志文件:

源文件:log.dirs=D:\kafak-project\logs
删除logs文件夹,,重新建立一个文件夹
log.dirs=D:\kafak-project\logs-k
重启解决问题
Logo

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

更多推荐