使用kafka-node使用使用者组自动提交消息

Question

我想在我的使用者组中完成所有任务完成后（如将消息推入数据库）手动提交消息。我如何手动禁用自动提交和提交消息。

Answer 1

使用node-rdkafka代替。它工作得很好。你可以犯下类似于

consumer.commit({ topic: data.topic, partition: data.partition, offset: data.offset + 1 }, function(err, data) {}) 

Answer 2

set auto commit enable is false。

auto.commit.enable=false 
consumer.commitOffsets(true) 

https://*.com/a/29952127/4652706