-
背景:
在测试kafaka connect时,每次为了清理脏数据,直接将topic删除掉,然后进入zk将相应的topic删除,一次一不小心将zk中的数据全部删除了,导致kafka启动不起来。
- 在kafka大神的指导下,选择了最简单也是最暴力的方法:将zk和kafka的数据全部清理干净,然后重启,具体步骤如下: 1.首先分别将zk和kafka进程停掉;
- 将zk配置文件zoo.cfg中配置的dataDir和dataLogDir中的数据除了myid文件外,其余的全部删除,然后重启zk,进而进入zk客户端执行:
rmr /admin/delete_topics
rmr /config
rmr /brokers/topics
rmr /consumers
rmr /schema_registry
- 将kafka中配置文件server.properties中的log.dirs下的文件全部清除,然后重启kafka即可成功。