Class DestinationTopic.Properties

java.lang.Object
org.springframework.kafka.retrytopic.DestinationTopic.Properties
Enclosing class:
DestinationTopic

public static class DestinationTopic.Properties extends Object
  • Constructor Details

    • Properties

      public 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).
      Parameters:
      delayMs - the delay in ms.
      suffix - the suffix.
      type - the type.
      maxAttempts - the max attempts.
      numPartitions - the number of partitions.
      dltStrategy - the DLT strategy.
      kafkaOperations - the KafkaOperations.
      shouldRetryOn - the exception classifications.
      timeout - the timeout.
    • Properties

      public Properties(DestinationTopic.Properties sourceProperties, String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type)
      Create an instance with the provided properties with the DLT container starting automatically.
      Parameters:
      sourceProperties - the source properties.
      suffix - the suffix.
      type - the type.
    • Properties

      public 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, @Nullable Boolean autoStartDltHandler)
      Create an instance with the provided properties.
      Parameters:
      delayMs - the delay in ms.
      suffix - the suffix.
      type - the type.
      maxAttempts - the max attempts.
      numPartitions - the number of partitions.
      dltStrategy - the DLT strategy.
      kafkaOperations - the KafkaOperations.
      shouldRetryOn - the exception classifications.
      timeout - the timeout.
      autoStartDltHandler - whether or not to start the DLT handler.
      Since:
      2.8
    • Properties

      public 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, @Nullable Boolean autoStartDltHandler, Set<Class<? extends Throwable>> usedForExceptions)
      Create an instance with the provided properties.
      Parameters:
      delayMs - the delay in ms.
      suffix - the suffix.
      type - the type.
      maxAttempts - the max attempts.
      numPartitions - the number of partitions.
      dltStrategy - the DLT strategy.
      kafkaOperations - the KafkaOperations.
      shouldRetryOn - the exception classifications.
      timeout - the timeout.
      autoStartDltHandler - whether or not to start the DLT handler.
      usedForExceptions - the exceptions which destination is intended for
      Since:
      3.2
  • Method Details

    • isDltTopic

      public boolean isDltTopic()
    • isRetryTopic

      public boolean isRetryTopic()
    • suffix

      public String suffix()
    • delay

      public long delay()
    • numPartitions

      public int numPartitions()
      Return the number of partitions the retry topics should be created with.
      Returns:
      the number of partitions.
      Since:
      2.7.13
    • autoStartDltHandler

      @Nullable public Boolean autoStartDltHandler()
    • usedForExceptions

      public Set<Class<? extends Throwable>> usedForExceptions()
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • isMainEndpoint

      public boolean isMainEndpoint()