返回到文章
1
源
采纳
编辑于
在名
kafka根据时间戳消费或者消费指定时间内的数据
kafka
很早就想要这个功能了
每次出了问题都是换一下消费者组id,然后数据又全部重新消费一遍,很痛苦
几个场景
从当前时间往前推2个小时开始接着消费,消费完这2个小时断开
从当前时间往前推2个小时开始接着持续消费
指定个时间戳开始持续消费
指定个开始时间与结束时间消费,消费完断开
预览