Class DestinationTopic

java.lang.Object
org.springframework.kafka.retrytopic.DestinationTopic

public class DestinationTopic extends Object
Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.
Since:
2.7
Author:
Tomaz Fernandes, Gary Russell
  • Constructor Details

  • Method Details

    • getDestinationDelay

      public Long getDestinationDelay()
    • getDestinationPartitions

      public Integer getDestinationPartitions()
    • isAlwaysRetryOnDltFailure

      public boolean isAlwaysRetryOnDltFailure()
    • isDltTopic

      public boolean isDltTopic()
    • isNoOpsTopic

      public boolean isNoOpsTopic()
    • isReusableRetryTopic

      public boolean isReusableRetryTopic()
    • isSingleTopicRetry

      @Deprecated public boolean isSingleTopicRetry()
      Deprecated.
      in favor of using DestinationTopic.Type.REUSABLE_RETRY_TOPIC and isReusableRetryTopic().
      Whether this is a single retry topic.
      Returns:
      whether this is a single retry topic.
    • isMainTopic

      public boolean isMainTopic()
    • getDestinationName

      public String getDestinationName()
    • getKafkaOperations

      public KafkaOperations<?,?> getKafkaOperations()
    • shouldRetryOn

      public boolean shouldRetryOn(Integer attempt, Throwable e)
    • toString

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

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

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

      public long getDestinationTimeout()