Class DestinationTopicPropertiesFactory

java.lang.Object

org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory

public class DestinationTopicPropertiesFactory
extends Object

Creates a list of DestinationTopic.Properties based on the provided configurations.

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell, João Lima, Wang Zhiyang, Adrian Chlebosz

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DestinationTopicPropertiesFactory.DestinationTopicSuffixes

Constructor Summary

Constructors

Constructor	Description
DestinationTopicPropertiesFactory(@Nullable String retryTopicSuffix, @Nullable String dltSuffix, List<Long> backOffValues, ExceptionMatcher exceptionMatcher, int numPartitions, KafkaOperations<?,?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout, Map<String, Set<Class<? extends Throwable>>> dltRoutingRules)	Construct an instance with the provided properties.
DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues, ExceptionMatcher exceptionMatcher, int numPartitions, KafkaOperations<?,?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout)	Construct an instance with the provided properties.

Method Summary

Modifier and Type	Method	Description
DestinationTopicPropertiesFactory	autoStartDltHandler(@Nullable Boolean autoStart)	Set to false to not start the DLT handler.
List<DestinationTopic.Properties>	createProperties()

Methods inherited from class java.lang.Object

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

Constructor Details

DestinationTopicPropertiesFactory

public DestinationTopicPropertiesFactory(String retryTopicSuffix,
 String dltSuffix,
 List<Long> backOffValues,
 ExceptionMatcher exceptionMatcher,
 int numPartitions,
 KafkaOperations<?,?> kafkaOperations,
 DltStrategy dltStrategy,
 TopicSuffixingStrategy topicSuffixingStrategy,
 SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy,
 long timeout)

Construct an instance with the provided properties.

Parameters:

retryTopicSuffix - the suffix.

dltSuffix - the dlt suffix.

backOffValues - the back off values.

exceptionMatcher - the exception matcher.

numPartitions - the number of partitions.

kafkaOperations - the operations.

dltStrategy - the dlt strategy.

topicSuffixingStrategy - the topic suffixing strategy.

sameIntervalTopicReuseStrategy - the same interval reuse strategy.

timeout - the timeout.

Since:

3.0.12

DestinationTopicPropertiesFactory

public DestinationTopicPropertiesFactory(@Nullable String retryTopicSuffix,
 @Nullable String dltSuffix,
 List<Long> backOffValues,
 ExceptionMatcher exceptionMatcher,
 int numPartitions,
 KafkaOperations<?,?> kafkaOperations,
 DltStrategy dltStrategy,
 TopicSuffixingStrategy topicSuffixingStrategy,
 SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy,
 long timeout,
 Map<String, Set<Class<? extends Throwable>>> dltRoutingRules)

Construct an instance with the provided properties.

Parameters:

retryTopicSuffix - the suffix.

dltSuffix - the dlt suffix.

backOffValues - the back off values.

exceptionMatcher - the exception matcher.

numPartitions - the number of partitions.

kafkaOperations - the operations.

dltStrategy - the dlt strategy.

topicSuffixingStrategy - the topic suffixing strategy.

sameIntervalTopicReuseStrategy - the same interval reuse strategy.

timeout - the timeout.

dltRoutingRules - the specification of which DLT should be used for the particular exception type

Since:

3.2.0

Method Details

autoStartDltHandler

public DestinationTopicPropertiesFactory autoStartDltHandler(@Nullable Boolean autoStart)

Set to false to not start the DLT handler.

Parameters:

autoStart - false to not start.

Returns:

this factory.

Since:

2.8

createProperties

public List<DestinationTopic.Properties> createProperties()