Uses of Class
org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
-
Uses of RetryTopicConfigurationBuilder in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionRetryTopicConfigurationBuilder.autoCreateTopics
(Boolean shouldCreate, Integer numPartitions, Short replicationFactor) Configure the topic creation behavior to optionally create topics with the provided properties.RetryTopicConfigurationBuilder.autoCreateTopicsWith
(Integer numPartitions, Short replicationFactor) Configure the topic creation behavior to auto create topics with the provided properties.RetryTopicConfigurationBuilder.autoStartDltHandler
(Boolean autoStart) Set to false to not start the DLT handler (configured or default); overrides the container factory's autoStartup property.RetryTopicConfigurationBuilder.concurrency
(Integer concurrency) Configure the concurrency for the retry and DLT containers.RetryTopicConfigurationBuilder.customBackoff
(org.springframework.retry.backoff.SleepingBackOffPolicy<?> backOffPolicy) Configure a customSleepingBackOffPolicy
.RetryTopicConfigurationBuilder.dltHandlerMethod
(String beanName, String methodName) Configure a DLT handler method.RetryTopicConfigurationBuilder.dltHandlerMethod
(EndpointHandlerMethod endpointHandlerMethod) Configure a DLT handler method.RetryTopicConfigurationBuilder.dltProcessingFailureStrategy
(DltStrategy dltStrategy) Configure theDltStrategy
.RetryTopicConfigurationBuilder.dltRoutingRules
(Map<String, Set<Class<? extends Throwable>>> dltRoutingRules) Configure to set DLT routing rules causing the message to be redirected to the custom DLT when the configured exception has been thrown during message processing.Configure the suffix to add to the DLT topic.RetryTopicConfigurationBuilder.doNotAutoCreateRetryTopics()
Configure the topic creation behavior to NOT auto create topics.RetryTopicConfigurationBuilder.doNotConfigureDlt()
Configure theDltStrategy
toDltStrategy.NO_DLT
.RetryTopicConfigurationBuilder.doNotRetryOnDltFailure()
Configure theDltStrategy
toDltStrategy.FAIL_ON_ERROR
.RetryTopicConfigurationBuilder.excludeTopic
(String topicName) Configure a topic name for which the target configuration will NOT be used.RetryTopicConfigurationBuilder.excludeTopics
(List<String> topicNames) Configure the topic names for which the target configuration will NOT be used.RetryTopicConfigurationBuilder.exponentialBackoff
(long initialInterval, double multiplier, long maxInterval) Configure anExponentialBackOffPolicy
.RetryTopicConfigurationBuilder.exponentialBackoff
(long initialInterval, double multiplier, long maxInterval, boolean withRandom) Configure anExponentialBackOffPolicy
orExponentialRandomBackOffPolicy
depending on the random parameter.RetryTopicConfigurationBuilder.fixedBackOff
(int interval) Configure aFixedBackOffPolicy
.RetryTopicConfigurationBuilder.fixedBackOff
(long interval) Configure aFixedBackOffPolicy
.RetryTopicConfigurationBuilder.includeTopic
(String topicName) Configure a topic name for which to use the target configuration.RetryTopicConfigurationBuilder.includeTopics
(List<String> topicNames) Configure the topic names for which to use the target configuration.RetryTopicConfigurationBuilder.listenerFactory
(String factoryBeanName) Configure the container factory to use via its bean name.RetryTopicConfigurationBuilder.listenerFactory
(ConcurrentKafkaListenerContainerFactory<?, ?> factory) Configure the container factory to use.RetryTopicConfigurationBuilder.maxAttempts
(int maxAttempts) Configure the maximum delivery attempts (including the first).RetryTopicConfigurationBuilder.newInstance()
Create a new instance of the builder.RetryTopicConfigurationBuilder.noBackoff()
Configure aNoBackOffPolicy
.RetryTopicConfigurationBuilder.notRetryOn
(Class<? extends Throwable> throwable) Configure the behavior to NOT retry on the providedThrowable
.RetryTopicConfigurationBuilder.notRetryOn
(List<Class<? extends Throwable>> throwables) Configure the behavior to NOT retry on the providedThrowable
s.Configure the behavior to retry on the providedThrowable
.Configure the behavior to retry on the providedThrowable
s.RetryTopicConfigurationBuilder.retryTopicSuffix
(String suffix) Configure the suffix to add to the retry topics.RetryTopicConfigurationBuilder.sameIntervalTopicReuseStrategy
(SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy) Configure theSameIntervalTopicReuseStrategy
.RetryTopicConfigurationBuilder.setTopicSuffixingStrategy
(TopicSuffixingStrategy topicSuffixingStrategy) Configure the retry topic nameTopicSuffixingStrategy
.RetryTopicConfigurationBuilder.suffixTopicsWithIndexValues()
Configure the retry topic names to be suffixed with ordinal index values.RetryTopicConfigurationBuilder.timeoutAfter
(long timeout) Configure a global timeout, in milliseconds, after which a record will go straight to the DLT the next time a listener throws an exception.RetryTopicConfigurationBuilder.traversingCauses()
Configure the classifier to traverse the cause chain.RetryTopicConfigurationBuilder.traversingCauses
(boolean traversing) Configure the classifier to traverse, or not, the cause chain.RetryTopicConfigurationBuilder.uniformRandomBackoff
(long minInterval, long maxInterval) Configure aUniformRandomBackOffPolicy
.RetryTopicConfigurationBuilder.useSingleTopicForSameIntervals()
Configure the use of a single retry topic for the attempts that have the same backoff interval (as long as these attempts are in the end of the chain).