北京住房城乡建设部网站八大员,更新wordpress主机名,黑龙江建筑信息网,网页制作模板文件的扩展名kafka正确设置过期时间 背景如何正确配置数据过期时间 背景
某天突然发现我的kafka中group_id消费记录不见了#xff0c;特地查了下咋回事。众所周知新版本的kafka group_id消费的offset记录已经不存储在zookeeper上了#xff0c;而是存储在__consumer_offsets 这个kafka内部… kafka正确设置过期时间 背景如何正确配置数据过期时间 背景
某天突然发现我的kafka中group_id消费记录不见了特地查了下咋回事。众所周知新版本的kafka group_id消费的offset记录已经不存储在zookeeper上了而是存储在__consumer_offsets 这个kafka内部自己管理的topic中这个topic有50个分区。 毫无疑问估计是group_id offset存储也应该是有时间过期值的于是专门查了查。
如何正确配置数据过期时间
需要两个参数结合且最好配置的时间是一样的下面是例子
#存储一年
log.retention.hours8760 -数据过期时间
offsets.retention.minutes525600 -group_id offset的消费位点过期时间。 换算成小时也是一年
