Class ErrorHandlingUtils
- java.lang.Object
-
- org.springframework.kafka.listener.ErrorHandlingUtils
-
public final class ErrorHandlingUtils extends java.lang.ObjectUtilities for error handling.- Since:
- 2.8
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static java.lang.StringrecordsToString(org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records)Represent the records as a comma-delimited String oftopic-part@offset.static voidretryBatch(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, java.lang.Runnable invokeListener, org.springframework.util.backoff.BackOff backOff, CommonErrorHandler seeker, java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>,java.lang.Exception> recoverer, org.springframework.core.log.LogAccessor logger, KafkaException.Level logLevel)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.
-
-
-
Method Detail
-
retryBatch
public static void retryBatch(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, java.lang.Runnable invokeListener, org.springframework.util.backoff.BackOff backOff, CommonErrorHandler seeker, java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>,java.lang.Exception> recoverer, org.springframework.core.log.LogAccessor logger, KafkaException.Level logLevel)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. When retries are exhausted, call the recoverer with theConsumerRecords.- Parameters:
thrownException- the exception.records- the records.consumer- the consumer.container- the container.invokeListener- theRunnableto run (call the listener).backOff- the backOff.seeker- the common error handler that re-seeks the entire batch.recoverer- the recoverer.logger- the logger.logLevel- the log level.
-
recordsToString
public static java.lang.String recordsToString(org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records)
Represent the records as a comma-delimited String oftopic-part@offset.- Parameters:
records- the records.- Returns:
- the String.
-
-