我在kafka中有给定主题的分区号和偏移号之间的映射。我想使用golang从头开始到所有特定的分区/偏移量映射使用所有消息。简而言之，我想知道是否有可能从头到特定的偏移量使用kafka中的消息。
我想知道在开始实现某些东西之前是否有内置工具或库可以帮助我。
最佳答案
我将其发布为答案，因为我有99.9％的人相信这是正确的-您无法在使用者上指定结束偏移量。消费者API支持OOTB:
请注意，没有指定范围的选项，但是您可以轻松地做到这一点:只需从头开始，到阅读完所需数量的消息(例如最终的偏移量)时就停止。
请参阅the Official API中的
Controlling Consumer Position部分
关于go - 如何从开始到特定偏移量消耗消息，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/58572143/