Package for retryable topic handling.
-
Returns the enum constant of this class with the specified name.
TopicSuffixingStrategy.values()
Returns an array containing the constants of this enum class, in
the order they are declared.
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.