Class DestinationTopic.Properties
- java.lang.Object
-
- org.springframework.kafka.retrytopic.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.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Boolean
autoStartDltHandler()
long
delay()
boolean
equals(java.lang.Object o)
int
hashCode()
boolean
isDltTopic()
boolean
isMainEndpoint()
int
numPartitions()
Return the number of partitions the retry topics should be created with.java.lang.String
suffix()
java.lang.String
toString()
-
-
-
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
- theKafkaOperations
.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
- theKafkaOperations
.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 classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
isMainEndpoint
public boolean isMainEndpoint()
-
-