写了一个测试kafka的demo,运行的时候报如下错误

 Caused by: org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is java.lang.IllegalStateException: Topic(s) [test] is/are not present and missingTopicsFatal is true
	at 

windows解决办法

1、记得不要把开启zookeeper和kafka的cmd关闭!!!我把开启zookeeper的cmd和开启kafka的cmd界面都关闭了,小白真是狗生艰难。
2、开启了之后,发现还是报错。大佬教了个办法,说是windows上的kafka不稳定,可能造成的原因是cmd启动zookeeper的时候,卡住了,这个时候点击鼠标右键,会发现又往下跳了几行数据。(原谅我表述可能不太清楚)。这时候zookeeper才算开启成功。
经过以上两步,kafka的测试demo才通过了。
这里简单记录下自己遇到的bug,对于kafka目前还有一脑子的疑惑没解决。表达不准确之处还请见谅

Logo

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

更多推荐