Interface DeliveryAttemptAware
-
- All Known Implementing Classes:
DefaultAfterRollbackProcessor
,FailedRecordProcessor
,RecoveringBatchErrorHandler
,SeekToCurrentErrorHandler
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface DeliveryAttemptAware
A component implementing this interface can provide the next delivery attempt.- Since:
- 2.5
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
deliveryAttempt(TopicPartitionOffset topicPartitionOffset)
Return the next delivery attempt for the topic/partition/offset.
-
-
-
Method Detail
-
deliveryAttempt
int deliveryAttempt(TopicPartitionOffset topicPartitionOffset)
Return the next delivery attempt for the topic/partition/offset.- Parameters:
topicPartitionOffset
- the topic/partition/offset.- Returns:
- the next delivery attempt.
-
-