kafka如何根据开始结束时间定位开始结束的位移?

想喝好几罐八宝粥的男孩 发表于: 2021-07-13   最后更新时间: 2021-07-13 11:20:00   62 游览

现在有这么个需求,设置开始结束时间,然后寻找kafka这个时间段内的开始和结束的位移,这个好实现吗?求教了



添加评论

很简单呀,你已经看过这篇文章里,这里就有答案:
https://www.orchome.com/1004

consumer.offsetsForTimes(startMap);

这个就是根据时间戳,返回的消费者分区和当下的offset。

谢谢你的提醒,我现在找到答案了。

找不到想要的答案?

我要提问
提问