---

title: Kafka Topic 保留与压缩策略配置指南

keywords:

  • Kafka
  • cleanup.policy
  • retention.ms
  • min.cleanable.dirty.ratio
  • segment.bytes

description: 配置主题的保留与压缩策略(Delete/Compact),提供命令与参数说明,保障日志与状态主题的高效管理。

tags:

  • Kafka
  • cleanup.policy
  • min.cleanable.dirty.ratio
  • retention.ms
  • segment.bytes
  • 后端
  • 消息队列

categories:

  • 文章资讯
  • 技术教程

---

Kafka Topic 保留与压缩策略配置指南

常用参数

  • cleanup.policy=delete|compact|delete,compact
  • retention.ms=604800000(7 天)
  • segment.bytes=1073741824(1 GiB)
  • min.cleanable.dirty.ratio=0.5

创建或更新主题

# 创建日志型主题(按时间删除)
kafka-topics --bootstrap-server localhost:9092 --create --topic logs --partitions 6 --replication-factor 3 --config cleanup.policy=delete --config retention.ms=604800000

# 为状态型主题启用压缩
kafka-configs --bootstrap-server localhost:9092 --alter --topic state --add-config cleanup.policy=compact --add-config min.cleanable.dirty.ratio=0.5

验证

kafka-configs --bootstrap-server localhost:9092 --describe --topic state

总结

日志型主题用 delete 保留,状态主题用 compact 去重;合理设置保留与段大小可提升存储与清理效率。

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论
立即
投稿

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部