KafkaActor currently uses kafkajs auto-commit (at-least-once). Add a manual-commit mode where the actor re-emits offsets along with consumed records and waits for an explicit { kind: 'commit', offset } from the handler before advancing. Closes the gap for apps that need exactly-once-with-processing semantics.
KafkaActor currently uses kafkajs auto-commit (at-least-once). Add a manual-commit mode where the actor re-emits offsets along with consumed records and waits for an explicit { kind: 'commit', offset } from the handler before advancing. Closes the gap for apps that need exactly-once-with-processing semantics.