Uses of Class
org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder
-
Uses of RetryTopicConfigurationBuilder in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionRetryTopicConfigurationBuilder.autoCreateTopics
(boolean shouldCreate, int numPartitions, short replicationFactor) RetryTopicConfigurationBuilder.autoCreateTopicsWith
(int numPartitions, short replicationFactor) RetryTopicConfigurationBuilder.autoStartDltHandler
(Boolean autoStart) Set to false to not start the DLT handler (configured or default); overrides the container factory's autoStartup property.RetryTopicConfigurationBuilder.customBackoff
(org.springframework.retry.backoff.SleepingBackOffPolicy<?> backOffPolicy) RetryTopicConfigurationBuilder.dltHandlerMethod
(String beanName, String methodName) Configure a DLT handler method.RetryTopicConfigurationBuilder.dltHandlerMethod
(EndpointHandlerMethod endpointHandlerMethod) RetryTopicConfigurationBuilder.dltProcessingFailureStrategy
(DltStrategy dltStrategy) RetryTopicConfigurationBuilder.doNotAutoCreateRetryTopics()
RetryTopicConfigurationBuilder.doNotConfigureDlt()
RetryTopicConfigurationBuilder.doNotRetryOnDltFailure()
RetryTopicConfigurationBuilder.excludeTopic
(String topicName) RetryTopicConfigurationBuilder.excludeTopics
(List<String> topicNames) RetryTopicConfigurationBuilder.exponentialBackoff
(long initialInterval, double multiplier, long maxInterval) RetryTopicConfigurationBuilder.exponentialBackoff
(long initialInterval, double multiplier, long maxInterval, boolean withRandom) RetryTopicConfigurationBuilder.fixedBackOff
(int interval) RetryTopicConfigurationBuilder.fixedBackOff
(long interval) RetryTopicConfigurationBuilder.includeTopic
(String topicName) RetryTopicConfigurationBuilder.includeTopics
(List<String> topicNames) RetryTopicConfigurationBuilder.listenerFactory
(String factoryBeanName) RetryTopicConfigurationBuilder.listenerFactory
(ConcurrentKafkaListenerContainerFactory<?, ?> factory) RetryTopicConfigurationBuilder.maxAttempts
(int maxAttempts) RetryTopicConfigurationBuilder.newInstance()
Create a new instance of the builder.RetryTopicConfigurationBuilder.noBackoff()
RetryTopicConfigurationBuilder.notRetryOn
(Class<? extends Throwable> throwable) RetryTopicConfigurationBuilder.notRetryOn
(List<Class<? extends Throwable>> throwables) RetryTopicConfigurationBuilder.retryTopicSuffix
(String suffix) RetryTopicConfigurationBuilder.setTopicSuffixingStrategy
(TopicSuffixingStrategy topicSuffixingStrategy) RetryTopicConfigurationBuilder.suffixTopicsWithIndexValues()
RetryTopicConfigurationBuilder.timeoutAfter
(long timeout) RetryTopicConfigurationBuilder.traversingCauses()
RetryTopicConfigurationBuilder.traversingCauses
(boolean traversing) RetryTopicConfigurationBuilder.uniformRandomBackoff
(long minInterval, long maxInterval) RetryTopicConfigurationBuilder.useSingleTopicForFixedDelays()
RetryTopicConfigurationBuilder.useSingleTopicForFixedDelays
(FixedDelayStrategy useSameTopicForFixedDelays)