大家好,我是好学的小师弟。前段时间,在做测试的时候,发现一个问题。我的kafka-tool连接上了kafka,但是tool上的brokers下面的代理为空,topics也是一样,里面没有内容。后来询问同事,发现一位同事在做测试的时候,觉得数据量太多了,把一个topic删了,又重新建了一个。。。。。。。。该操作导致了这个问题的发生>_<  后来找了好久,找到了解决方法。

解决方法:

删除所有的topic信息包括zookeeper里的,因为topic被删除了一次,所以offset对不上了,导致了该问题的发生。

注意:该方法仅适用于不关心kafka数据的环境,慎用、慎用、慎用。生产环境禁止使用,用了也差不多准备交接了吧

步骤:

1.进入到kafka安装目录,关掉kafka进程

sh kafka-server-stop.sh

2.删除kafka的所有topics,一个个删除

./kafka-topics.sh --zookeeper 192.168.100.77:2181  --delete --topic "你的topic名字"

3.确定kafka日志存放目录,删除kafka日志

cd /home/kafka/kafka/kafka-1.1.0/config     
#这里是以我的路径为例
ll
#查看所有的配置文件

vim server.properties
#进入到配置文件里,定位kafka存放的路径

log.dirs=/data01/kafka-logs


删除该路径下的kafka-logs文件夹下的所有日志

4.进入zookeeper

 zookeeper-client

5.查看有哪些topics

ls /brokers/topics

6.删除zookeeper里的关于topic的信息(rm指令使用前,请再三思考)

rmr /brokers/topics/topicname

rmr /config/topics/topicname

#将所有topic删除

7.重启kafka服务

sh kafka-server-start.sh

新人创作不易,觉得不错的看官,点个赞吧,么么哒!!!

转载注明出处!

                                                            

Logo

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

更多推荐