首页/数据/数据工程与 ETL 速查/kafka-topics.sh 删除主题
Kafka64 条

kafka-topics.sh 删除主题

删除主题是高风险操作:配置与数据不可恢复(除非有其他副本或备份)。删除前确认无生产者写入、无消费者依赖,并评估重建的必要性。

命令--delete --topic <名字>
前提集群开启主题删除能力(delete.topic.enable)
后果数据与位移记录一并清理,不可逆

删除前核对

删除前核对
kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic orders
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --all-groups --describe | grep orders

kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic orders
删除确认是终态操作:建议先改名下线或停写观察,再执行删除。

易错点

  • 旧版本删除是“标记删除”,需要等待清理,重复执行删除命令可能报主题仍存在
  • 共享集群中同名主题可能被别的团队使用,删除前先看消费组与流量归属

数据来源与参考

  • Apache Kafka 官方文档:Topic Deletion
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌