liftbridge-io / go-liftbridge

Go client for Liftbridge. https://github.com/liftbridge-io/liftbridge
Apache License 2.0
66 stars 18 forks source link

Deal with failed message #102

Closed mehran-prs closed 3 years ago

mehran-prs commented 3 years ago

How do you handle failed messages? I can not see a feature to send nack

tylertreat commented 3 years ago

Liftbridge does not have a notion of acking (or nacking) since it's not a message queue but rather an append-only log. There is, however, an API that allows consumers to store cursors so that they can checkpoint positions in the log and resume consumption. In the future, consumer groups will extend this to make checkpointing more transparent to users.

In the case of a failed message, the consumer would need to update its position in the log to account for the message.

mehran-prs commented 3 years ago

Thanks @tylertreat