Uses of Class
org.springframework.kafka.support.ExceptionMatcher
Packages that use ExceptionMatcher
Package
Description
Package for kafka listeners
Package for retryable topic handling.
Package for kafka support
-
Uses of ExceptionMatcher in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener that return ExceptionMatcherModifier and TypeMethodDescriptionprotected ExceptionMatcher
ExceptionClassifier.getExceptionMatcher()
Return theExceptionMatcher
.Methods in org.springframework.kafka.listener with parameters of type ExceptionMatcherModifier 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, ExceptionMatcher exceptionMatcher, 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. -
Uses of ExceptionMatcher in org.springframework.kafka.retrytopic
Constructors in org.springframework.kafka.retrytopic with parameters of type ExceptionMatcherModifierConstructorDescriptionDestinationTopicPropertiesFactory
(@Nullable String retryTopicSuffix, @Nullable String dltSuffix, List<Long> backOffValues, ExceptionMatcher exceptionMatcher, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout, Map<String, Set<Class<? extends Throwable>>> dltRoutingRules) Construct an instance with the provided properties.DestinationTopicPropertiesFactory
(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues, ExceptionMatcher exceptionMatcher, int numPartitions, KafkaOperations<?, ?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout) Construct an instance with the provided properties. -
Uses of ExceptionMatcher in org.springframework.kafka.support
Methods in org.springframework.kafka.support that return ExceptionMatcherModifier and TypeMethodDescriptionExceptionMatcher.Builder.build()
Build anExceptionMatcher
.static ExceptionMatcher
ExceptionMatcher.defaultMatcher()
Create a matcher that matches anyException
, but not errors.