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はfalseです。

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

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