Kafka误删zk元数据,全部删除(仅限测试环境)

  • 背景:

    在测试kafaka connect时,每次为了清理脏数据,直接将topic删除掉,然后进入zk将相应的topic删除,一次一不小心将zk中的数据全部删除了,导致kafka启动不起来。


  1. 在kafka大神的指导下,选择了最简单也是最暴力的方法:将zk和kafka的数据全部清理干净,然后重启,具体步骤如下: 1.首先分别将zk和kafka进程停掉;
  2. 将zk配置文件zoo.cfg中配置的dataDir和dataLogDir中的数据除了myid文件外,其余的全部删除,然后重启zk,进而进入zk客户端执行:
rmr /admin/delete_topics
rmr /config
rmr /brokers/topics
rmr /consumers
rmr /schema_registry
  1. 将kafka中配置文件server.properties中的log.dirs下的文件全部清除,然后重启kafka即可成功。

猜你喜欢

转载自my.oschina.net/112612/blog/1798099