使用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://stackoverflow.com/a/29952127/4652706