Non-blocking retries with Spring Kafka batch consumer
@RetryableTopic
is not supported with batch listeners.
The RecoveringBatchErrorHandler
(DefaultErrorHandler
for 2.8 and later) supports sending a failed record within a batch to a dead letter topic, with the help of the listener throwing a BatchListenerFailedException
indicating which record failed.
You would then have to implement your own listener on that topic.