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, Wang Zhiyang, Adrian Chlebosz
  • 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

      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, Map<String,Set<Class<? extends Throwable>>> dltRoutingRules)
      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.
      dltRoutingRules - the specification of which DLT should be used for the particular exception type
      Since:
      3.2.0
  • Method Details