Package org.springframework.kafka.retrytopic

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

  • Method Details

    • isDltTopic

      public boolean isDltTopic()

    • 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()

    • 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()