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

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

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

kafka

发表于 2021-07-13

想喝好几罐八宝粥的男孩

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

consumer.offsetsForTimes(startMap);

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

回答于 3年前

半兽人

想喝好几罐八宝粥的男孩 -> 半兽人 3年前

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

查看kafka相关的其他问题或提一个您自己的问题。

提问