Uses of Class
org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
Packages that use RetryTopicConfigurationBuilder
-
Uses of RetryTopicConfigurationBuilder in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic that return RetryTopicConfigurationBuilderModifier and TypeMethodDescriptionRetryTopicConfigurationBuilder.autoCreateTopics
(@Nullable Boolean shouldCreate, @Nullable Integer numPartitions, @Nullable Short replicationFactor) Configure the topic creation behavior to optionally create topics with the provided properties.RetryTopicConfigurationBuilder.autoCreateTopicsWith
(@Nullable Integer numPartitions, @Nullable Short replicationFactor) Configure the topic creation behavior to auto-create topics with the provided properties.RetryTopicConfigurationBuilder.autoStartDltHandler
(@Nullable 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
(BackOff backOff) Configure a customBackOff
.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 anExponentialBackOff
.RetryTopicConfigurationBuilder.exponentialBackoff
(long initialInterval, double multiplier, long maxInterval, long jitter) Configure anExponentialBackOff
with a jitter value.RetryTopicConfigurationBuilder.fixedBackOff
(int interval) Configure aFixedBackOff
.RetryTopicConfigurationBuilder.fixedBackOff
(long interval) Configure aFixedBackOff
.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
(@Nullable 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 aBackOff
that does not apply any delay.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
(@Nullable 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) Deprecated, for removal: This API element is subject to removal in a future version.RetryTopicConfigurationBuilder.useSingleTopicForSameIntervals()
Configure the use of a single retry topic for the attempts that have the same back off interval (as long as these attempts are in the end of the chain).
exponentialBackoff(long, double, long)