---
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,compactretention.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 去重;合理设置保留与段大小可提升存储与清理效率。

发表评论 取消回复