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
I have a long running message while processing a file where the partition is sometimes revoked. I have a handler that is called when this happens. Is it possible to commit the offset when that occurs? I've tried different things in the handler and can't figure out a way to get an instance of the consumer to commit the offset or commit another way.
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
-
I have a long running message while processing a file where the partition is sometimes revoked. I have a handler that is called when this happens. Is it possible to commit the offset when that occurs? I've tried different things in the handler and can't figure out a way to get an instance of the consumer to commit the offset or commit another way.
Beta Was this translation helpful? Give feedback.
All reactions