删除kafka topic数据

log.retention.{ms,minutes,hours}: Kafka segment log的保存周期, 默认保存7天

1. 把retention.ms 改小, 如1000ms, 即1分钟

./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --alter --add-config retention.ms=1000 --entity-name MyTopic

查看设置是否成功:

./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --describe --entity-name MyTopic

2. 5分钟后,查看日志文件是否已经删除或者文件大小是否变小

ll /data/storage/kafka/

为什么是5分钟? 跟这个配置有关, log.retention.check.interval.ms: 删除策略的检查周期

3. 把retention.ms 恢复原值

./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --alter --delete-config retention.ms --entity-name MyTopic

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容