pipeline: Let .AutoCommit determine when messages are committed

moov-io / achgateway

Payment gateway enabling automated ACH operations in a distributed and fault tolerant way.

https://moov-io.github.io/achgateway/

Apache License 2.0

52 stars 19 forks source link

pipeline: Let .AutoCommit determine when messages are committed #165

Closed adamdecaf closed 1 year ago

adamdecaf commented 1 year ago

Previously we were always committing messages before processing (either in the kafka consumer layer or before application processing). This didn't allow users of achgateway to wait until messages were successfully handled to acknowledge messages, which can lead to unprocessed (but acknowledged) messages.