如何消费从头到特定偏移量的消息

Question

我有 kafka 中给定主题的分区号和偏移量之间的映射。我想使用 golang 消耗从头开始到特定分区/偏移映射的所有消息。简而言之，我想知道是否可以从头到特定偏移量消费kafka中的消息。

我想知道在开始实施某些事情之前是否有内置工具或库可以帮助我做一些事情。

Answer 1

因为我 99.9% 相信这是正确的 - 您无法指定 Consumer 上的结束偏移量。Consumer API 支持 OOTB：从头开始。从任意位置开始。从最后开始。请注意，没有指定范围的选项，但您可以轻松地自己执行此操作：只需从头开始，并在读取所需数量的消息（例如最终偏移量）后停止。