Class DestinationTopic.Properties
java.lang.Object
org.springframework.kafka.retrytopic.DestinationTopic.Properties
- Enclosing class:
- DestinationTopic
-
Constructor Summary
ConstructorDescriptionProperties
(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).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, Boolean autoStartDltHandler) Create an instance with the provided properties.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, Boolean autoStartDltHandler, Set<Class<? extends Throwable>> usedForExceptions) Create an instance with the provided properties.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. -
Method Summary
-
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
- theKafkaOperations
.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
- theKafkaOperations
.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
- theKafkaOperations
.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
-
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
-
usedForExceptions
-
equals
-
hashCode
public int hashCode() -
toString
-
isMainEndpoint
public boolean isMainEndpoint()
-