Package for retryable topic handling.
-
Returns the enum constant of this class with the specified name.
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.
Properties(long delayMs,
String suffix,
org.springframework.kafka.retrytopic.DestinationTopic.Type type,
int maxAttempts,
int numPartitions,
DltStrategy dltStrategy,
KafkaOperations<?,?> kafkaOperations,
BiPredicate<Integer,Throwable> shouldRetryOn,
long timeout)
Create an instance with the provided properties with the DLT container starting
automatically (if the container factory is so configured).
Properties(long delayMs,
String suffix,
org.springframework.kafka.retrytopic.DestinationTopic.Type type,
int maxAttempts,
int numPartitions,
DltStrategy dltStrategy,
KafkaOperations<?,?> kafkaOperations,
BiPredicate<Integer,Throwable> shouldRetryOn,
long timeout,
Boolean autoStartDltHandler)
Create an instance with the provided properties.
Properties(long delayMs,
String suffix,
org.springframework.kafka.retrytopic.DestinationTopic.Type type,
int maxAttempts,
int numPartitions,
DltStrategy dltStrategy,
KafkaOperations<?,?> kafkaOperations,
BiPredicate<Integer,Throwable> shouldRetryOn,
long timeout,
Boolean autoStartDltHandler,
Set<Class<? extends Throwable>> usedForExceptions)
Create an instance with the provided properties.