Kafka中,可以通过设置offset来指定消费位置。有两种方法可以实现从指定位置消费:
使用消费者组(Consumer Group)和offset保存的方式:
auto.offset.reset
设置为earliest
或latest
)或者手动管理(auto.offset.reset
设置为none
)。seek()
方法来设置消费者的offset,从而指定消费的起始位置。使用特定的partition和offset进行消费:
assign()
方法来手动分配要消费的partition和offset,例如:consumer.assign(Arrays.asList(new TopicPartition("topicName", 0)));
consumer.seek(new TopicPartition("topicName", 0), offset);
需要注意的是,如果在消费过程中出现了新的消息,消费者将从指定位置继续消费,而不会跳过这些新消息。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:kafka怎么从指定offset消费