我有Kafka中给定主题的分区数和偏移数之间的Map。我想使用golang使用从开始到那些特定分区/偏移Map的所有消息。简言之，我想知道是否有可能消费Kafka的信息从一开始到一个特定的偏移量。我想知道是否有内置的工具或库，可以帮助我做之前，我开始实施的东西。
k5ifujac1#
我张贴这个作为一个答案，因为我像99.9%相信这是正确的-你不能指定消费者的结束抵消。使用者api支持ootb：从头开始。从任意位置开始。从最后开始。请注意，没有指定范围的选项，但您可以自己轻松地进行指定：只需从开始处开始，并在读取了所需数量的消息（例如，最终偏移量）后停止。参见章节 Controlling Consumer Position 在官方api中
Controlling Consumer Position
1条答案
按热度按时间k5ifujac1#
我张贴这个作为一个答案，因为我像99.9%相信这是正确的-你不能指定消费者的结束抵消。使用者api支持ootb：
从头开始。
从任意位置开始。
从最后开始。
请注意，没有指定范围的选项，但您可以自己轻松地进行指定：只需从开始处开始，并在读取了所需数量的消息（例如，最终偏移量）后停止。
参见章节
Controlling Consumer Position在官方api中