Uses of Enum Class
org.springframework.kafka.KafkaException.Level
Package
Description
Base package for kafka
Package for kafka listeners
-
Uses of KafkaException.Level in org.springframework.kafka
Modifier and TypeMethodDescriptionstatic KafkaException.Level
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.ModifierConstructorDescriptionKafkaException
(String message, KafkaException.Level level, Throwable cause) Construct an instance with the provided properties. -
Uses of KafkaException.Level in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionprotected KafkaException.Level
KafkaExceptionLogLevelAware.getLogLevel()
Set the level at which the exception thrown by this handler is logged.Modifier and TypeMethodDescriptionstatic 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) Deprecated.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.
ErrorHandlingUtils.retryBatch(Exception, ConsumerRecords, Consumer, MessageListenerContainer, Runnable, BackOff, CommonErrorHandler, BiConsumer, LogAccessor, org.springframework.kafka.KafkaException.Level, List, BinaryExceptionClassifier, boolean)
.