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
Commit offset after processing or last processed record(s)
Does ConsumerRebalanceListener can be useful in these cases:
The first risk is the delay in next pool, because you are busy processing data from the last call. If you don't poll for a long, the group coordinator might assume that you are dead and trigger a rebalance activity. You don't want that to happen, Right? Because you were not dead, you were computing.
The second risk is also related to rebalancing. The coordinator triggers a rebalance activity for some other reason while you are processing an extensive list of messages.
Requirements:
enable.auto.commit
:false
Does ConsumerRebalanceListener can be useful in these cases:
All cases with solution described HERE
The text was updated successfully, but these errors were encountered: