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(boolean shouldCreate, int numPartitions, short replicationFactor) Configure the topic creation behavior to optionall create topics with the provided properties.RetryTopicConfigurationBuilder.autoCreateTopicsWith(int 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.Configure the suffix to add to the DLT topic.RetryTopicConfigurationBuilder.doNotAutoCreateRetryTopics()Configure the topic creation behavior to NOT auto create topics.RetryTopicConfigurationBuilder.doNotConfigureDlt()Configure theDltStrategytoDltStrategy.NO_DLT.RetryTopicConfigurationBuilder.doNotRetryOnDltFailure()Configure theDltStrategytoDltStrategy.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 anExponentialBackOffPolicyorExponentialRandomBackOffPolicydepending 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 providedThrowables.Configure the behavior to retry on the providedThrowable.Configure the behavior to retry on the providedThrowables.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.useSingleTopicForFixedDelays()Deprecated.RetryTopicConfigurationBuilder.useSingleTopicForFixedDelays(FixedDelayStrategy delayStrategy) Deprecated.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).
useSingleTopicForSameIntervals().