Package org.springframework.kafka.retrytopic

Class DestinationTopicPropertiesFactory

java.lang.Object

org.springframework.kafka.retrytopic.DestinationTopicPropertiesFactory

public class DestinationTopicPropertiesFactory
extends java.lang.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(java.lang.String retryTopicSuffix, java.lang.String dltSuffix, java.util.List<java.lang.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(java.lang.Boolean autoStart)	Set to false to not start the DLT handler.
java.util.List<DestinationTopic.Properties>	createProperties()

Methods inherited from class java.lang.Object

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

Constructor Detail

DestinationTopicPropertiesFactory

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

Method Detail

autoStartDltHandler

public DestinationTopicPropertiesFactory autoStartDltHandler(java.lang.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 java.util.List<DestinationTopic.Properties> createProperties()