You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hi!
I'm using StreamConsumer and want to implement exactly once delivery guarantee. From what I understand when committing transactions I may encounter errors which will require me to call abort_transaction on the producer - Will the StreamConsumer automatically go back to the commit of the transaction start on next poll, or do I need to track it and on abort manually call seek?
Thanks!
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
Hi!
I'm using StreamConsumer and want to implement exactly once delivery guarantee. From what I understand when committing transactions I may encounter errors which will require me to call
abort_transaction
on the producer - Will the StreamConsumer automatically go back to the commit of the transaction start on next poll, or do I need to track it and on abort manually call seek?Thanks!
Beta Was this translation helpful? Give feedback.
All reactions