kafka consumer offset 怎么用java代码手动设置commit

Question

如题，怎么用Java代码在consumer端，手动设置消息offset ​ commit​​

Answer 1

在参数配置文件里配置
http://debugo.com/kafka-params/

auto.commit.enable=false

手动提交是有些问题的，参考：

http://www.fwqtg.net/kafka-consumer%E9%98%B2%E6%AD%A2%E6%95%B0%E6%8D%AE%E4%B8%A2%E5%A4%B1-%E5%8D%9A%E5%AE%A2%E5%88%86%E7%B1%BB%EF%BC%9A-kafka-kafkaoffset-commit.html