kafka topic 删除异常
公司kafka集群是允许删除topic,但是前段时间组里小伙伴有个topic总是删不掉,也不知道他是怎么删的;后来我尝试手动删除zookeeper中的元数据,看看能否删掉这个topic,操作如下rmr /brokers/topics/nginx_clean_error_datarmr /admin/delete_topics/nginx_clean_error_data命令执行了,但是zookee
·
公司kafka集群是允许删除topic,但是前段时间组里小伙伴有个topic总是删不掉,也不知道他是怎么删的;后来我尝试手动删除zookeeper中的元数据,看看能否删掉这个topic,操作如下
rmr /brokers/topics/nginx_clean_error_data
rmr /admin/delete_topics/nginx_clean_error_data
命令执行了,但是zookeeper目录依旧存在,这就有点奇怪了,查看日志发现这个topic自动重建了,这也就是为什么zookeeper中的元数据一直删不掉;那为什么会自动创建?查了下资料,原因大致是,被异常删除的topic,kafka集群会尝试自动重新创建;那如何解决?
也很简单,在配置文件中设置关闭自动创建topic功能
auto.create.topics.enable=false
修改完,依次重启kafka 节点,再次删除zookeeper中改topic的元数据即可
更多推荐
已为社区贡献7条内容
所有评论(0)