删除topic数据

基于kafka2.0版本。

1.命令删除topic

// 查看所有topic
./kafka-topics.sh --list --zookeeper 【zookeeper server】
// 删除
./bin/kafka-topics  --delete --zookeeper 【zookeeper server】  --topic 【topic name】

[2019-02-25 15:52:00,070] WARN Connected to an old server; r-o mode will be unavailable (org.apache.zookeeper.ClientCnxnSocket) Topic test is marked for deletion. Note: This will have no impact if delete.topic.enable is not set to true.

提示删除给标记了。要设置参数delete.topic.enable才可以删除。一般都不设置。这时,磁盘还是没有释放空间的。

  • 现在默认启用主题删除,因为该功能现在已稳定。希望保留先前行为的用户应将代理配置设置delete.topic.enablefalse。请记住,删除主题会删除数据并且操作不可逆(即没有“取消删除”操作)

新版都默认删除了。可以设置为false不删除。

2.直接删除磁盘

直接查看server.properties的日志记录目录。

默认:log.dirs=/tmp/kafka-logs

直接清空这个目录。

要注意 zk 对应的节点信息也要清空。除了/zookeeper和自己的业务相关节点,其他的都删除掉。

**缺点:**会删除全部的topic。

上次更新时间: 2024/5/7 05:59:02