kafka 系列：设置日志数据保存过期时间（含某个 topic）、日志策略_NIO4444-CSDN 博客_kafka 配置数据过期时间

> 本文由 [简悦 SimpRead](http://ksria.com/simpread/) 转码， 原文地址 [blog.csdn.net](https://blog.csdn.net/VIP099/article/details/106257561)

全局设置（h）
=======

server.properties

```
log.retention.hours=72
log.cleanup.policy=delete
```

某个 Topic 设置（ms）
===============

比如 topic：xdoctorx

```
./kafka-configs.sh --zookeeper localhost:2181 --alter --entity-name xdoctorx --entity-type topics --add-config retention.ms=86400000 
```

查看是否生效

```
./kafka-config --zookeeper localhsot:2181 --describle --entity-name xdoctorx --entity_type topics
```

立刻删除（now）
=========

```
./kafka-topics.sh --zookeeper localhost:2181 --alter --topic xdoctorx --config cleanup.policy=delete 
```

查看是否生效

```
./kafka-topics.sh --zookeeper localhost:2181 --topic xdoctorx --describe 
```

日志策略
====

**分段策略属性**
----------

<table><thead><tr><th>属性名</th><th>含义</th><th>默认值</th></tr></thead><tbody><tr><td>log.roll.{hours,ms}</td><td>日志滚动的周期时间，到达指定周期时间时，强制生成一个新的 segment</td><td>168（7day）</td></tr><tr><td><span>log.segment.bytes</span></td><td><span>每个 segment 的最大容量。到达指定容量时，将强制生成一个新的 segment</span></td><td><span>1G(-1 为不限制)</span></td></tr><tr><td>log.retention.check.interval.ms</td><td>日志片段文件检查的周期时间</td><td>60000</td></tr></tbody></table>

**日志刷新策略**
----------

Kafka 的日志实际上是开始是在缓存中的，然后根据策略定期一批一批写入到日志文件中去，以提高吞吐率。

<table><thead><tr><th>属性名</th><th>含义</th><th>默认值</th></tr></thead><tbody><tr><td><span>log.flush.interval.messages</span></td><td><span>消息达到多少条时将数据写入到日志文件</span></td><td><span>10000</span></td></tr><tr><td><span>log.flush.interval.ms</span></td><td><span>当达到该时间时，强制执行一次 flush</span></td><td><span>null</span></td></tr><tr><td>log.flush.scheduler.interval.ms</td><td>周期性检查，是否需要将信息 flush</td><td>很大的值</td></tr></tbody></table>

**日志保存清理策略**
------------

<table><thead><tr><th>属性名</th><th>含义</th><th>默认值</th></tr></thead><tbody><tr><td>log.cleanup.polict</td><td>日志清理保存的策略只有 delete 和 compact 两种</td><td>delete</td></tr><tr><td><span>log.retention.hours</span></td><td><span>日志保存的时间，可以选择 hours,minutes 和 ms</span></td><td><span>168(7day)</span></td></tr><tr><td><span>log.retention.bytes</span></td><td><span>删除前日志文件允许保存的最大值</span></td><td><span>-1</span></td></tr><tr><td>log.segment.delete.delay.ms</td><td>日志文件被真正删除前的保留时间</td><td>60000</td></tr><tr><td>log.cleanup.interval.mins</td><td>每隔一段时间多久调用一次清理的步骤</td><td>10</td></tr><tr><td><span>log.retention.check.interval.ms</span></td><td><span>周期性检查是否有日志符合删除的条件（新版本使用）</span></td><td><span>300000</span></td></tr></tbody></table>

日志删除，只是无法被索引到了而已。文件本身仍然是存在的，只有当过了 log.segment.delete.delay.ms 这个时间以后，文件才会被真正的从文件系统中删除。

参考
==

[https://kafka.apache.org/documentation/#log.flush.interval.messages](https://kafka.apache.org/documentation/#log.flush.interval.messages)