公司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的元数据即可

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐