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

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, FixedDelayStrategy fixedDelayStrategy, DltStrategy dltStrategy, TopicSuffixingStrategy topicSuffixingStrategy, long timeout)

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,
 FixedDelayStrategy fixedDelayStrategy,
 DltStrategy dltStrategy,
 TopicSuffixingStrategy topicSuffixingStrategy,
 long timeout)

Method Details

autoStartDltHandler

public DestinationTopicPropertiesFactory autoStartDltHandler(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()