Reputation: 357
We are using manual commit strategy. We have configured a bean that commits all Successfully consumed messages. We are trying to add a logic to re-consume not acknowledged messages. We are facing problem that same message gets consumed but the time interval for re-consumption is not uniform. Sometimes gets re-consumed quickly, but sometimes takes hours.
How can we make sure that uncommitted messages gets consumed within a specified time.
Upvotes: 1
Views: 726
Reputation: 174799
You can perform a seek()
operation on the Consumer
to reset it to a specific offset.
Upvotes: 3