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

我想知道在开始实现某些东西之前是否有built-in工具或库可以帮助我。

分析解答

我将其发布为答案,因为我有99.9%的人认为这是正确的-您无法在使用者上指定结束偏移量。消费者API支持OOTB:

  1. 从头开始。
  2. 从任意位置开始。
  3. 从头开始。

请注意,没有指定范围的选项,但是您可以轻松地做到这一点:只需从头开始,到阅读完所需数量的消息(例如最终的偏移量)时停止即可。

请参阅官方API中的Controlling Consumer Position部分