org.springframework.integration.kafka.listener
Interface Acknowledgment
- All Known Implementing Classes:
- DefaultAcknowledgment
public interface Acknowledgment
Handle for acknowledging the processing of a KafkaMessage. Recipients can store the reference in
asynchronous scenarios, but the internal state should be assumed transient (i.e. it cannot be serialized
and deserialized later)
- Since:
- 1.0.1
- Author:
- Marius Bogoevici
|
Method Summary |
void |
acknowledge()
Invoked when the message for which the acknowledgment has been created has been processed. |
acknowledge
void acknowledge()
- Invoked when the message for which the acknowledgment has been created has been processed.
Calling this method implies that all the previous messages in the partition have been processed already.