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

chris chelio 发表于: 2018-11-07   最后更新时间: 2018-11-07 22:33:55   1,838 游览

Kafka版本:kafka_2.10-0.10.1.1

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

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

发表于 2018-11-07
添加评论

那不能,除非你seek的时间的记录已经被删除了。

你的答案

查看kafka相关的其他问题或提一个您自己的问题