宁波网站建设是哪家便宜,金融网站开发文档下载,如何制作可以下单的网站,宝安中心有什么好玩的地方文章目录一、kafka 全局消息过期时间设置1. 配置文件夹2. 修改配置3. 重启配置生效二、针对特定topic设置过期时间2.1. 配置文件夹2.2. 执行设置命令三、kafka过期消息删除过程一、kafka 全局消息过期时间设置
1. 配置文件夹
进入kafka配置文件夹
/app/kafka_2.12-2.2.0/con…
文章目录一、kafka 全局消息过期时间设置1. 配置文件夹2. 修改配置3. 重启配置生效二、针对特定topic设置过期时间2.1. 配置文件夹2.2. 执行设置命令三、kafka过期消息删除过程一、kafka 全局消息过期时间设置
1. 配置文件夹
进入kafka配置文件夹
/app/kafka_2.12-2.2.0/config默认的是在server.properties 文件里面
2. 修改配置
需要修改和配置项如下
log.retention.hours168 (配置该参数即可)
log.cleanup.policydelete 默认可不配置我这里设置的是24小时也就是一天 3. 重启配置生效
修改配置后重启kafka服务生效kafka默认的消息过期时间为168h(7天)
该种设置消息过期时间的优点是可以对所有topic全部生效缺点是需要重启kafka服务造成服务短暂的不可用
二、针对特定topic设置过期时间
实际上可以不停服针对kafka中数据量较大的topic可以单独设置过期时间不受全局过期时间的限制而且不需要重启kafka
下面以数据较多的 mytopic为例 全局默认消息过期时间为7天现在将其调整为1天
2.1. 配置文件夹
cd /app/kafka_2.12-2.2.0/config2.2. 执行设置命令 前提已设置kafka环境变量 ./kafka-configs.sh --zookeeper 192.168.0.101:2181 --alter --entity-name mytopic --entity-type topics --add-config retention.ms86400000时间设置一天 86400000ms 1天
三、kafka过期消息删除过程
kafka消息首先由用户设定一个或多个partition每个partition中kafka会根据消息量来逐步建立多个segment存储消息每个segment的大小由配置项进行设定比如这里
log.segment.bytes1073741824 【1GB】kafka至少会保留1个工作segment保存消息。消息量超过单个文件存储大小就会新建segment比如消息量为2.6GB, 就会建立3个segment。kafka会定时扫描非工segment将该文件时间和设置的topic过期时间进行对比如果发现过期就会将该segment文件具体包括一个log文件和两个index文件打上.deleted 的标记如下所示
-rw-r--r-- 1 root root 1073740353 Nov 13 03:02 00000000000108550131.log.deleted
-rw-r--r-- 1 root root 526304 Nov 13 03:02 00000000000108550131.index.deleted
-rw-r--r-- 1 root root 697704 Nov 13 03:02 00000000000108550131.timeindex.deleted最后kafka中会有专门的删除日志定时任务过来扫描发现.deleted文件就会将其从磁盘上删除释放磁盘空间至此kafka过期消息删除完成。
可以看出kafka删除消息是以segment为维度的而不是以具体的一条条消息为维度。一个segment包含了一段时期的全部消息并存储在一个文件中比如上文提到的 00000000000108550131.log
删除时是一次性把这个过期的文件包含所有消息全部删除效率非常高。可以设想如果是先判断一条条的消息时间是否过期再一条条的执行删除将十分影响kafka的性能和效率频繁擦除磁盘对硬盘性能也有较大影响
所以如果消息量不多没有超过一个segment的存储容量由于kafka至少要保留一个segment用于存取消息所以也不会去删除里面过期的消息。实际上也存在着设置了消息7天过期但是kafka里面仍存在着10天前的数据这就是由kafka的删除特性决定的。
我们删除过期消息的目的是为了释放磁盘空间既然消息很少没有突破一个segment的容量那么即使多保留几天的旧消息又何妨又不怎么占用磁盘空间。然而这种删除策略的设计换来的却是大消息量的topic整块消息删除的高性能和高效率 不得不说这种设计理念非常先进
