1. 从一次深夜告警说起当Kafka磁盘被写满时那天凌晨两点手机突然开始疯狂震动。监控系统发来一连串告警线上核心业务系统的Kafka集群其中一个Broker节点的磁盘使用率在短短半小时内从70%飙升到了98%并且还在持续上涨。消息生产端开始出现大量超时和发送失败消费端也出现了严重的消息延迟。整个团队被紧急唤醒大家的第一反应就是“日志清理策略是不是没生效”这几乎是每个Kafka运维或开发都会遇到的经典场景。Kafka的设计哲学是“日志即存储”所有消息都以顺序追加的方式写入磁盘日志文件Log Segment。这种设计带来了极高的吞吐量但也把磁盘空间管理这个“脏活累活”完全交给了使用者。默认配置下Kafka并不会因为磁盘快满了就自动删除旧数据它只认自己那套基于时间或大小的日志保留策略。这就导致了一个常见的认知误区很多人以为配好了log.retention.hours1687天7天前的数据就会自动消失磁盘空间就会循环利用。但实际上如果7天前的日志段Segment因为各种原因比如有活跃的消费者连接、副本同步滞后没有被清理而新的数据又源源不断地涌入磁盘被写满只是一个时间问题。当磁盘使用率达到100%时Kafka Broker会直接拒绝新的写入请求因为操作系统已经无法分配新的磁盘块来创建日志文件。此时不仅仅是这个Broker上的分区不可用如果这些分区是某个主题Topic的关键分区或者生产者配置了acksall可能会导致整个生产流程阻塞。更棘手的是Broker进程本身也可能因为无法写入自己的内部日志如controller日志而变得不稳定甚至崩溃。所以处理Kafka磁盘写满不是一个简单的“删文件”操作而是一个需要理解其内部机制、评估影响、并谨慎执行的应急流程。接下来我会结合那次实战和后续的复盘详细拆解从问题诊断到彻底解决的全过程。2. 诊断你的磁盘为什么被写满了接到告警后切忌直接登录服务器执行rm -rf。第一步永远是先搞清楚“是什么”和“为什么”。我们需要沿着一条清晰的排查链路定位问题的根源。2.1 确认磁盘使用情况与Kafka日志目录首先通过SSH连接到出问题的Broker节点使用df -h命令查看磁盘整体使用情况。重点确认是哪个挂载点例如/data或/kafka空间不足。然后使用du -sh /your/kafka/log/dir/*命令快速查看Kafka数据目录下各个主题Topic的磁盘占用情况。通常你会发现某个或某几个主题的日志目录体积异常庞大。注意Kafka的日志目录结构通常是log.dirs配置的路径例如/data/kafka-logs其下是按主题名和分区号组织的文件夹如your-large-topic-0/。2.2 检查日志保留策略配置这是最关键的一步。我们需要检查问题主题的实际生效的日志保留策略。Kafka的配置具有层级性Broker级别、主题级别、客户端级别覆盖。通过Kafka自带的命令行工具进行查询是最准确的方式。# 查看特定主题的配置重点关注以retention开头的配置项 ./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name your-large-topic --describe # 或者使用更早版本的命令如果集群版本较老 ./kafka-topics.sh --zookeeper localhost:2181 --topic your-large-topic --describe你需要关注的配置项主要有三个retention.ms 日志保留的毫秒数。这是最高优先级的配置。如果设置了它会覆盖retention.minutes和retention.hours。retention.bytes 分区级别的日志保留大小字节。这是整个分区所有日志段的总大小上限。这是一个非常容易被忽略但极其重要的配置。cleanup.policy 清理策略默认是delete删除也可以是compact压缩。我们讨论的通常是delete。一个常见的坑是只设置了时间保留策略但没有设置大小保留策略。假设你设置了retention.ms6048000007天但你的业务流量巨大7天内产生的数据量可能高达1TB。如果你的磁盘只有500GB那么在第4天磁盘可能就被撑满了但Kafka会认为第1天的数据还没到7天所以不会删除它们导致磁盘写满。2.3 检查日志段Log Segment状态即使时间或大小策略满足了删除条件Kafka也不是实时删除文件的。它以后台线程Log Cleaner的方式定期扫描并删除过期的日志段。我们需要检查是否有日志段“卡住”了没有被清理。进入具体分区的日志目录列出文件cd /data/kafka-logs/your-large-topic-0 ls -la你会看到两类主要文件.log文件 实际存储消息的日志段文件。.index和.timeindex文件 偏移量和时间索引文件。Kafka的清理是以日志段为单位的。一个日志段只有在满足以下两个条件时才会被删除条件一可删除 该日志段的“最后修改时间”实际上是该段最后一条消息的时间戳早于当前时间 - retention.ms。条件二可删除 删除该日志段后分区总日志大小仍大于retention.bytes。使用kafka-dump-log.sh工具可以查看日志段的详细信息包括基准偏移量Base Offset和最大时间戳。./kafka-dump-log.sh --files /data/kafka-logs/your-large-topic-0/00000000000012345678.log --print-data-log | head -20查看输出中的maxTimestamp字段可以判断这个日志段的最新消息是什么时候。如果它远早于保留时间但却依然存在那可能就是清理线程出了问题。2.4 检查Log Cleaner线程状态Log Cleaner是负责执行删除操作的后台线程。如果它挂了或者太忙清理工作就会停滞。可以通过JMX指标或Kafka日志来检查。JMX指标 使用JConsole或JMX工具连接Broker查看kafka.log:typeLogCleanerManager,namecleaner-thread-0相关的指标如max-dirty-percent脏数据比例和cleaner-thread-0的状态。日志排查 查看Kafka的 server.log 文件搜索 “Cleaning log” 或 “Log cleaner” 相关的日志。如果长时间没有清理日志或者有大量的错误信息说明清理器可能遇到了问题。常见问题包括清理线程数 (log.cleaner.threads) 设置过少或者磁盘IO瓶颈导致清理速度跟不上数据写入速度。2.5 检查消费者组偏移量这是另一个极其重要的排查点。Kafka不会删除那些仍然被活跃消费者消费的消息。即使消息已经超过了保留时间只要还有一个消费者组的当前偏移量Current Offset指向该消息所在的日志段这个日志段就会被保护起来不会被删除。通过以下命令检查消费该主题的所有消费者组的偏移量情况./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group your-consumer-group --describe查看输出中的LOG-END-OFFSET(LEO) 和CURRENT-OFFSET。如果某个分区的CURRENT-OFFSET长期远小于LOG-END-OFFSET并且差值对应的消息时间已经远超保留时间那么这些旧消息就会因为消费者的滞后而无法被清理。这种情况常出现在消费逻辑出错、消费者进程挂掉但未正确退出等场景。3. 应急操作安全释放磁盘空间诊断清楚原因后如果是线上紧急情况我们需要立即采取行动释放空间恢复服务。这里有几个按风险从低到高排列的操作方案。3.1 方案一动态调整主题保留策略首选如果确定是保留时间或大小设置不合理这是最安全、最推荐的方式。我们可以动态修改主题配置无需重启Broker。场景假设原配置retention.ms6048000007天但磁盘只有500G7天数据量有1T。操作将保留时间临时缩短或增加大小限制。# 将保留时间临时调整为24小时 ./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name your-large-topic --alter --add-config retention.ms86400000 # 或者更激进地同时设置一个明确的大小限制例如10GB ./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name your-large-topic --alter --add-config retention.bytes10737418240生效时间配置变更后Log Cleaner会在下一次清理周期由log.retention.check.interval.ms控制默认5分钟检测到新策略并开始清理过期数据。你会看到磁盘空间逐渐释放。优点在线操作对生产流量影响最小符合Kafka自身逻辑。风险如果消费者偏移量严重滞后此方法可能依然无效。需要结合消费者组排查。3.2 方案二手动删除最旧的日志段文件高风险需谨慎如果方案一因为消费者滞后等原因无法快速生效磁盘空间已告罄100%服务已受影响可以考虑手动删除。这是一个非常危险的操作必须严格按照步骤进行并做好备份和回滚准备。核心原则只删除已经关闭Closed的日志段。Kafka正在写入的当前活跃日志段Active Segment绝对不能动。操作步骤确认活跃段 在分区目录下文件名数字最小的那个.log文件不一定是活跃段。更准确的方法是看文件大小是否还在增长或者通过JMX查看分区的LogEndOffset对应的段文件。一个保守的做法是不要动最近1小时内创建的任何.log文件。停止相关生产者/消费者可选但建议 为了绝对安全可以临时停止向该主题生产消息或停止消费该主题分区的消费者。这可以防止在删除过程中发生不可预料的偏移量错误。执行删除 假设经过判断00000000000010000000.log及其对应的.index和.timeindex文件是已经关闭的旧段可以删除。cd /data/kafka-logs/your-large-topic-0 rm -f 00000000000010000000.log 00000000000010000000.index 00000000000010000000.timeindex重要 必须同时删除同名的.log、.index、.timeindex三个文件保持一致性。重启Broker有时需要 Kafka在启动时会加载所有日志段文件来构建元数据。手动删除文件后如果Kafka Broker进程正在运行它可能仍然在内存中持有这些文件的引用或者会在下次扫描时发现文件丢失而产生错误。最干净的做法是在删除一批旧文件后重启该Broker节点。重启会迫使Kafka重新加载剩余的文件建立正确的元数据视图。警告重启单个Broker会导致该Broker上的分区领导权转移在重启期间这些分区暂时不可用。请在业务低峰期操作并确保副本因子Replication Factor大于1以保证高可用。3.3 方案三使用kafka-delete-records.sh工具折中方案Kafka从某个版本开始提供了一个相对官方的工具来删除旧记录。它通过将分区的起始偏移量Log Start Offset向前推进来实现“删除”。这个操作本质上是在日志中打一个标记真正的物理删除仍然由Log Cleaner后续完成。但它能立即释放索引等元数据占用的部分资源并让更旧的数据对消费者“不可见”。# 1. 首先创建一个JSON文件指定要删除到的偏移量。例如想删除分区0偏移量10000000之前的所有记录。 cat delete-records.json EOF { partitions: [ { topic: your-large-topic, partition: 0, offset: 10000000 } ], version: 1 } EOF # 2. 执行删除命令 ./kafka-delete-records.sh --bootstrap-server localhost:9092 --offset-json-file delete-records.json优点 比手动删文件更“规范”Kafka内部能更好地处理。缺点 1. 不会立即释放大量磁盘空间因为.log文件还在。2. 如果指定的偏移量仍然被某个消费者组消费该消费者组会收到OFFSET_OUT_OF_RANGE错误。3. 需要精确知道要删除到哪个偏移量操作复杂度高。4. 根治与预防构建稳定的磁盘管理策略应急处理只是治标我们需要一套治本的预防性策略避免问题再次发生。4.1 配置合理的保留策略不要只依赖时间策略。一个健壮的配置应该是时间和大小双重约束。时间策略 (retention.ms) 根据业务需求设定例如审计要求保存30天则设为2592000000。大小策略 (retention.bytes)必须设置。根据log.dirs所在磁盘的总容量、其他主题的占用、以及预留的缓冲空间建议至少20%来计算。例如磁盘500G预留100G单个分区最大可设为(500-100)*0.8/分区数假设多个分区均匀分布。在主题级别设置./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name your-topic --alter --add-config retention.bytes107374182400 # 100GB这样即使数据没到保留时间但总大小超过100GB后最旧的日志段也会被删除为磁盘上了“双保险”。4.2 监控与告警建立完善的监控体系将问题扼杀在萌芽状态。磁盘使用率监控 对每个Broker节点的数据目录磁盘使用率设置告警建议在85%时触发警告90%时触发严重告警。主题增长监控 监控关键主题的日志大小增长速率和预估填满时间。可以使用Kafka的JMX指标kafka.log:typeLog,nameSize,topic*,partition*或通过kafka-log-dirs.sh脚本定期采集。消费者滞后监控 监控所有消费者组的Lag滞后消息数。对于关键业务设置滞后阈值告警例如滞后超过10万条。长期滞后的消费者是磁盘空间无法释放的元凶之一。Log Cleaner活动监控 监控Log Cleaner线程是否活跃以及清理速率。如果长时间没有清理活动需要立即排查。4.3 容量规划与扩容容量规划是根本。定期评估业务数据增长量计算所需的磁盘空间。计算公式所需总空间 每日数据增量 × 保留天数 × 副本因子 × (1 索引等元数据开销系数)预留缓冲 永远不要将磁盘用到接近100%。为操作系统、Kafka其他文件、临时峰值预留至少20%-30%的空间。水平扩容 当单个Broker磁盘无法满足时考虑增加Broker节点并将主题分区重新分布这是更优雅的扩容方式。4.4 处理“僵尸”消费者组对于那些已经停止消费但偏移量长期不更新的“僵尸”消费者组需要定期清理。可以使用kafka-consumer-groups.sh命令删除它们或者配置offsets.retention.minutes默认7天让Kafka自动删除过期的偏移量。删除后对应的旧日志段将不再受保护可以被正常清理。# 删除指定的消费者组 ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group zombie-group --delete4.5 考虑日志压缩Log Compaction对于Key-Value模型且只关心最新状态的数据如数据库变更日志CDC可以使用日志压缩策略 (cleanup.policycompact)。它只为每个Key保留最新的Value可以极大地节省空间。但这改变了Topic的语义需要业务逻辑适配。那次凌晨的紧急处理我们最终采用了组合方案首先动态将问题主题的retention.bytes设置为一个合理值快速抑制了磁盘使用率增长然后发现有一个测试用的消费者组已经停滞了数周导致大量旧数据无法删除我们果断删除了该消费者组最后在业务低峰期重启了受影响的Broker让清理策略完全生效。事后我们复盘并完善了监控对所有核心主题都加上了大小保留策略的双重保障。Kafka的磁盘管理就像保养一辆高性能跑车你不能只加汽油写数据还得定期换机油、检查刹车清理日志、监控容量。理解其内部机制配以合理的策略和监控才能让它稳定、高效地奔跑。
