作为一个在项目中边学边用的实习生,真的被昨天还好好的今天就不能消费数据的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

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐