How can we manually reset the offset of a kafka topic which is consumed through a spring boot java application?

My requirement is to reset the offset of a kafka topic when the application has failed to process the message read from current offset of kafka topic which is consumed through a spring boot java application.

After resetting the offset manually or sending a negative acknowledgement the messages needs to be polled again from the uncomitted offset value through the kafka consumer of spring boot java application. Can it be achieved?...

Read More »

By: StackOverFlow - Wednesday, 9 January

Related Posts