Package org.springframework.kafka.retrytopic

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(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?,?> kafkaOperations, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout)	Construct an instance with the provided properties.
DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, 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.

Method Summary

Modifier and Type	Method	Description
DestinationTopicPropertiesFactory	autoStartDltHandler(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,
 org.springframework.classify.BinaryExceptionClassifier exceptionClassifier,
 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.

exceptionClassifier - the exception classifier.

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(String retryTopicSuffix,
 String dltSuffix,
 List<Long> backOffValues,
 org.springframework.classify.BinaryExceptionClassifier exceptionClassifier,
 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.

exceptionClassifier - the exception classifier.

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