kafka一段时间内的检索数据筛选

想喝好几罐八宝粥的男孩 发表于: 2021-07-07   最后更新时间: 2021-07-07 11:14:57   86 游览

很早就想要这个功能了
每次出了问题都是换一下消费者组id,然后数据又全部重新消费一遍,很痛苦

几个场景
从当前时间往前推2个小时开始接着消费,消费完这2个小时断开
从当前时间往前推2个小时开始接着持续消费
指定个时间戳开始持续消费
指定个开始时间与结束时间消费,消费完断开。
请问一下,现在哪有这样的例子可以供参考?



添加评论

kafka通过开始和结束时间,重新消费消息
https://www.orchome.com/1004

找不到想要的答案?

我要提问
提问