Class DestinationTopic.Properties

  • Enclosing class:
    DestinationTopic

    public static class DestinationTopic.Properties
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      Constructor Description
      Properties​(long delayMs, java.lang.String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?,​?> kafkaOperations, java.util.function.BiPredicate<java.lang.Integer,​java.lang.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, java.lang.String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?,​?> kafkaOperations, java.util.function.BiPredicate<java.lang.Integer,​java.lang.Throwable> shouldRetryOn, long timeout, java.lang.Boolean autoStartDltHandler)
      Create an instance with the provided properties.
      Properties​(DestinationTopic.Properties sourceProperties, java.lang.String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type)
      Create an instance with the provided properties with the DLT container starting automatically.
    • Constructor Detail

      • Properties

        public Properties​(long delayMs,
                          java.lang.String suffix,
                          org.springframework.kafka.retrytopic.DestinationTopic.Type type,
                          int maxAttempts,
                          int numPartitions,
                          DltStrategy dltStrategy,
                          KafkaOperations<?,​?> kafkaOperations,
                          java.util.function.BiPredicate<java.lang.Integer,​java.lang.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,
                          java.lang.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,
                          java.lang.String suffix,
                          org.springframework.kafka.retrytopic.DestinationTopic.Type type,
                          int maxAttempts,
                          int numPartitions,
                          DltStrategy dltStrategy,
                          KafkaOperations<?,​?> kafkaOperations,
                          java.util.function.BiPredicate<java.lang.Integer,​java.lang.Throwable> shouldRetryOn,
                          long timeout,
                          @Nullable
                          java.lang.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 Detail

      • isDltTopic

        public boolean isDltTopic()
      • suffix

        public java.lang.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 java.lang.Boolean autoStartDltHandler()
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

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

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

        public boolean isMainEndpoint()