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 ExceptionMatcherExceptionClassifier.getExceptionMatcher()Return theExceptionMatcher.Methods in org.springframework.kafka.listener with parameters of type ExceptionMatcherModifier and TypeMethodDescriptionstatic voidErrorHandlingUtils.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 ExceptionMatcherExceptionMatcher.defaultMatcher()Create a matcher that matches anyException, but not errors.