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) 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)