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

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, FixedDelayStrategy fixedDelayStrategy, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, long timeout)	Deprecated. in favor of DestinationTopicPropertiesFactory(String, String, List, BinaryExceptionClassifier, int, KafkaOperations, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long)
DestinationTopicPropertiesFactory(String retryTopicSuffix, String dltSuffix, List<Long> backOffValues, org.springframework.classify.BinaryExceptionClassifier exceptionClassifier, int numPartitions, KafkaOperations<?,?> kafkaOperations, FixedDelayStrategy fixedDelayStrategy, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy, long timeout)	Deprecated. in favor of DestinationTopicPropertiesFactory(String, String, List, BinaryExceptionClassifier, int, KafkaOperations, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long)

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

@Deprecated
public DestinationTopicPropertiesFactory(String retryTopicSuffix,
 String dltSuffix,
 List<Long> backOffValues,
 org.springframework.classify.BinaryExceptionClassifier exceptionClassifier,
 int numPartitions,
 KafkaOperations<?,?> kafkaOperations,
 FixedDelayStrategy fixedDelayStrategy,
 DltStrategy dltStrategy,
 TopicSuffixingStrategy topicSuffixingStrategy,
 long timeout)

Deprecated.

in favor of DestinationTopicPropertiesFactory(String, String, List, BinaryExceptionClassifier, int, KafkaOperations, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long)

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.

fixedDelayStrategy - the fixed delay strategy.

dltStrategy - the dlt strategy.

topicSuffixingStrategy - the topic suffixing strategy.

timeout - the timeout.

DestinationTopicPropertiesFactory

@Deprecated
public DestinationTopicPropertiesFactory(String retryTopicSuffix,
 String dltSuffix,
 List<Long> backOffValues,
 org.springframework.classify.BinaryExceptionClassifier exceptionClassifier,
 int numPartitions,
 KafkaOperations<?,?> kafkaOperations,
 FixedDelayStrategy fixedDelayStrategy,
 DltStrategy dltStrategy,
 TopicSuffixingStrategy topicSuffixingStrategy,
 SameIntervalTopicReuseStrategy sameIntervalTopicReuseStrategy,
 long timeout)

Deprecated.

in favor of DestinationTopicPropertiesFactory(String, String, List, BinaryExceptionClassifier, int, KafkaOperations, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long)

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.

fixedDelayStrategy - the fixed delay strategy.

dltStrategy - the dlt strategy.

topicSuffixingStrategy - the topic suffixing strategy.

sameIntervalTopicReuseStrategy - the same interval reuse strategy.

timeout - the timeout.

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