作为一个在项目中边学边用的实习生,真的被昨天还好好的今天就不能消费数据的kafka折磨到了,下面提供一点建议,希望能对大家有所帮助。

//操作前集群都关了

1.首先去kafka-home的config目录下找到server.properties文件,

加入advertised.listeners=PLAINTEXT://ip:9092    如果有配置listener,注释掉,让他使用默认的0.0.0.0(每台kafka集群的主机都这样,ip也不一样)

2.然后查看server.properties文件记录的log.dir参数(存放数据的地方),把这个目录直接删掉,

是删目录,不是删参数。

3.去你的zookeeper目录下,开启客户端,bin/zkCli.sh

删掉kafka目录下的brokers目录,命令是deleteall /kafka/brokers

具体目录大家不一定一样,可以自己查看目录再做更改,使用ls /命令查看根目录下的所有文件(中间有空格的)

我的博客即将同步至腾讯云开发者社区,邀请大家一同入驻:https://cloud.tencent.com/developer/support-plan?invite_code=1kwnj656n0ggy

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐