假设我有一个Kafka主题中特定消息的偏移量和分区，我如何将一个消费者附加到这个主题并只消费这些特定消息？例如，如果我有一个主题中消息的偏移量和分区，我想只消费这个消息，而不消费其他消息，这可能吗？
nnvyjq4y1#
您可以将一个消费者seek到一个分区+偏移量，然后在获得该事件时中断消费者循环。
seek
1条答案
按热度按时间nnvyjq4y1#
您可以将一个消费者
seek到一个分区+偏移量，然后在获得该事件时中断消费者循环。