Himanshu Singh
Himanshu Singh

Reputation: 357

Kafka : How to re-consume un committed / not Acknowledged message

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

Answers (1)

Gary Russell
Gary Russell

Reputation: 174799

You can perform a seek() operation on the Consumer to reset it to a specific offset.

Upvotes: 3

Related Questions