Spring Integration Kafka Support

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.
 

Method Detail

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.


Spring Integration Kafka Support