Automatisches Commit Nachrichten mit Consumer-Gruppe mit kafka-Knoten

Question

Ich möchte Nachrichten manuell, wenn alle Aufgaben abgeschlossen sind (wie Push-Nachricht in die Datenbank), in meiner Verbrauchergruppe. Wie kann ich automatische Commit- und Commit-Nachrichten manuell deaktivieren?

Answer 1

Verwenden node-rdkafka statt. Es funktioniert sehr gut . Sie können eine Nachricht wie

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

Answer 2

set auto commit enable ist falsch.

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

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