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

  • 背景:测试

    在测试kafaka connect时,每次为了清理脏数据,直接将topic删除掉,而后进入zk将相应的topic删除,一次一不当心将zk中的数据所有删除了,致使kafka启动不起来。code


  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便可成功。
相关文章
相关标签/搜索