Package for kafka listeners
-
void
void
Set one or more
RetryListener
to receive notifications of retries and
recovery.
static void
ErrorHandlingUtils.retryBatch(Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container,
Runnable invokeListener,
BackOff backOff,
CommonErrorHandler seeker,
BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>,Exception> recoverer,
LogAccessor logger,
KafkaException.Level logLevel,
List<RetryListener> retryListeners,
org.springframework.classify.BinaryExceptionClassifier classifier,
boolean reClassifyOnExceptionChange)
Retry a complete batch by pausing the consumer and then, in a loop, poll the
consumer, wait for the next back off, then call the listener.