Uses of Enum Class
org.springframework.kafka.KafkaException.Level

Packages that use KafkaException.Level

Package	Description
org.springframework.kafka	Base package for kafka
org.springframework.kafka.listener	Package for kafka listeners

Uses of KafkaException.Level in org.springframework.kafka

Methods in org.springframework.kafka that return KafkaException.Level

Modifier and Type	Method	Description
static KafkaException.Level	KafkaException.Level.valueOf(String name)	Returns the enum constant of this class with the specified name.
static KafkaException.Level[]	KafkaException.Level.values()	Returns an array containing the constants of this enum class, in the order they are declared.

Constructors in org.springframework.kafka with parameters of type KafkaException.Level

Modifier	Constructor	Description
	KafkaException(String message, KafkaException.Level level, Throwable cause)	Construct an instance with the provided properties.

Uses of KafkaException.Level in org.springframework.kafka.listener

Methods in org.springframework.kafka.listener that return KafkaException.Level

Modifier and Type	Method	Description
protected KafkaException.Level	KafkaExceptionLogLevelAware.getLogLevel()	Set the level at which the exception thrown by this handler is logged.

Methods in org.springframework.kafka.listener with parameters of type KafkaException.Level

Modifier and Type	Method	Description
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.
static void	SeekUtils.seekOrRecover(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, boolean commitRecovered, BiPredicate<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,Exception> skipPredicate, LogAccessor logger, KafkaException.Level level)	Seek the remaining records, optionally recovering the first.
static void	SeekUtils.seekOrRecover(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, boolean commitRecovered, RecoveryStrategy recovery, LogAccessor logger, KafkaException.Level level)	Seek the remaining records, optionally recovering the first.
void	FailedBatchProcessor.setLogLevel(KafkaException.Level logLevel)
void	KafkaExceptionLogLevelAware.setLogLevel(KafkaException.Level logLevel)	Set the level at which the exception thrown by this handler is logged.