删除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.enable
为false
。请记住,删除主题会删除数据并且操作不可逆(即没有“取消删除”操作)
新版都默认删除了。可以设置为false不删除。
2.直接删除磁盘
直接查看server.properties
的日志记录目录。
默认:log.dirs=/tmp/kafka-logs
直接清空这个目录。
要注意 zk 对应的节点信息也要清空。除了/zookeeper
和自己的业务相关节点,其他的都删除掉。
**缺点:**会删除全部的topic。
← linux安装kafka 消费者→