Package org.springframework.kafka.retrytopic

Class RetryTopicConfigurationBuilder

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

public class RetryTopicConfigurationBuilder
extends Object

Builder class to create RetryTopicConfiguration instances.

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell

Constructor Summary

Constructors

Constructor	Description
RetryTopicConfigurationBuilder()

Method Summary

Modifier and Type	Method	Description
RetryTopicConfigurationBuilder	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.
RetryTopicConfiguration	create(KafkaOperations<?,?> sendToTopicKafkaTemplate)
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	dltSuffix(String suffix)
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)
static 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	retryOn(Class<? extends Throwable> throwable)
RetryTopicConfigurationBuilder	retryOn(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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RetryTopicConfigurationBuilder

public RetryTopicConfigurationBuilder()

Method Details

dltHandlerMethod

public RetryTopicConfigurationBuilder dltHandlerMethod(String beanName,
 String methodName)

Configure a DLT handler method.

Parameters:

beanName - the bean name.

methodName - the method name.

Returns:

the builder.

Since:

2.8

dltHandlerMethod

public RetryTopicConfigurationBuilder dltHandlerMethod(EndpointHandlerMethod endpointHandlerMethod)

doNotRetryOnDltFailure

public RetryTopicConfigurationBuilder doNotRetryOnDltFailure()

dltProcessingFailureStrategy

public RetryTopicConfigurationBuilder dltProcessingFailureStrategy(DltStrategy dltStrategy)

doNotConfigureDlt

public RetryTopicConfigurationBuilder doNotConfigureDlt()

autoStartDltHandler

public RetryTopicConfigurationBuilder autoStartDltHandler(@Nullable
 Boolean autoStart)

Set to false to not start the DLT handler (configured or default); overrides the container factory's autoStartup property.

Parameters:

autoStart - false to not auto start.

Returns:

this builder.

Since:

2.8

includeTopics

public RetryTopicConfigurationBuilder includeTopics(List<String> topicNames)

excludeTopics

public RetryTopicConfigurationBuilder excludeTopics(List<String> topicNames)

includeTopic

public RetryTopicConfigurationBuilder includeTopic(String topicName)

excludeTopic

public RetryTopicConfigurationBuilder excludeTopic(String topicName)

retryTopicSuffix

public RetryTopicConfigurationBuilder retryTopicSuffix(String suffix)

dltSuffix

public RetryTopicConfigurationBuilder dltSuffix(String suffix)

suffixTopicsWithIndexValues

public RetryTopicConfigurationBuilder suffixTopicsWithIndexValues()

setTopicSuffixingStrategy

public RetryTopicConfigurationBuilder setTopicSuffixingStrategy(TopicSuffixingStrategy topicSuffixingStrategy)

maxAttempts

public RetryTopicConfigurationBuilder maxAttempts(int maxAttempts)

timeoutAfter

public RetryTopicConfigurationBuilder timeoutAfter(long timeout)

exponentialBackoff

public RetryTopicConfigurationBuilder exponentialBackoff(long initialInterval,
 double multiplier,
 long maxInterval)

exponentialBackoff

public RetryTopicConfigurationBuilder exponentialBackoff(long initialInterval,
 double multiplier,
 long maxInterval,
 boolean withRandom)

fixedBackOff

public RetryTopicConfigurationBuilder fixedBackOff(long interval)

uniformRandomBackoff

public RetryTopicConfigurationBuilder uniformRandomBackoff(long minInterval,
 long maxInterval)

noBackoff

public RetryTopicConfigurationBuilder noBackoff()

customBackoff

public RetryTopicConfigurationBuilder customBackoff(org.springframework.retry.backoff.SleepingBackOffPolicy<?> backOffPolicy)

fixedBackOff

public RetryTopicConfigurationBuilder fixedBackOff(int interval)

useSingleTopicForFixedDelays

public RetryTopicConfigurationBuilder useSingleTopicForFixedDelays()

useSingleTopicForFixedDelays

public RetryTopicConfigurationBuilder useSingleTopicForFixedDelays(FixedDelayStrategy useSameTopicForFixedDelays)

doNotAutoCreateRetryTopics

public RetryTopicConfigurationBuilder doNotAutoCreateRetryTopics()

autoCreateTopicsWith

public RetryTopicConfigurationBuilder autoCreateTopicsWith(int numPartitions,
 short replicationFactor)

autoCreateTopics

public RetryTopicConfigurationBuilder autoCreateTopics(boolean shouldCreate,
 int numPartitions,
 short replicationFactor)

retryOn

public RetryTopicConfigurationBuilder retryOn(Class<? extends Throwable> throwable)

notRetryOn

public RetryTopicConfigurationBuilder notRetryOn(Class<? extends Throwable> throwable)

retryOn

public RetryTopicConfigurationBuilder retryOn(List<Class<? extends Throwable>> throwables)

notRetryOn

public RetryTopicConfigurationBuilder notRetryOn(List<Class<? extends Throwable>> throwables)

traversingCauses

public RetryTopicConfigurationBuilder traversingCauses()

traversingCauses

public RetryTopicConfigurationBuilder traversingCauses(boolean traversing)

listenerFactory

public RetryTopicConfigurationBuilder listenerFactory(ConcurrentKafkaListenerContainerFactory<?,?> factory)

listenerFactory

public RetryTopicConfigurationBuilder listenerFactory(String factoryBeanName)

create

public RetryTopicConfiguration create(KafkaOperations<?,?> sendToTopicKafkaTemplate)

newInstance

public static RetryTopicConfigurationBuilder newInstance()

Create a new instance of the builder.

Returns:

the new instance.