返回到文章

采纳

编辑于

question about the api of Kafkaconsumer.seek(tp,of)?

kafka

Kafka版本:kafka_2.10-0.10.1.1

场景:为防止偏移量重置到最开始的情况(曾经出现过,消费者关闭重启后,偏移量到最开始的地方),使用本地编写的程序使用Kafkaconsumer.seek(tp,of)将偏移量设置到指定位置。

结果:成功设置偏移量后,发现项目中的消费者在拉取的时候没有从修改后的偏移量位置进行消费,而是从修改之前的地方消费的。但是如果用本地的程序去消费就可以从修改后的位置进行。