Package org.springframework.kafka.listener

Class ErrorHandlingUtils

java.lang.Object

org.springframework.kafka.listener.ErrorHandlingUtils

public final class ErrorHandlingUtils
extends Object

Utilities for error handling.

Since:

2.8

Author:

Gary Russell

Method Summary

Modifier and Type	Method	Description
static String	recordsToString(org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records)	Represent the records as a comma-delimited String of topic-part@offset.
static void	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)	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

retryBatch

public static void 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)

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 the ConsumerRecords.

Parameters:

thrownException - the exception.

records - the records.

consumer - the consumer.

container - the container.

invokeListener - the Runnable to 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 String recordsToString(org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records)

Represent the records as a comma-delimited String of topic-part@offset.

Parameters:

records - the records.

Returns:

the String.