org.springframework.integration.kafka.listener
Class DefaultAcknowledgment

java.lang.Object
  extended by org.springframework.integration.kafka.listener.DefaultAcknowledgment
All Implemented Interfaces:
Acknowledgment

public class DefaultAcknowledgment
extends java.lang.Object
implements Acknowledgment

Default implementation for an Acknowledgment that defers to an underlying OffsetManager.

Since:
1.0.1

Constructor Summary
DefaultAcknowledgment(OffsetManager offsetManager, KafkaMessage message)
           
DefaultAcknowledgment(OffsetManager offsetManager, Partition partition, java.lang.Long offset)
           
 
Method Summary
 void acknowledge()
          Invoked when the message for which the acknowledgment has been created has been processed.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultAcknowledgment

public DefaultAcknowledgment(OffsetManager offsetManager,
                             Partition partition,
                             java.lang.Long offset)

DefaultAcknowledgment

public DefaultAcknowledgment(OffsetManager offsetManager,
                             KafkaMessage message)
Method Detail

acknowledge

public void acknowledge()
Description copied from interface: Acknowledgment
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.

Specified by:
acknowledge in interface Acknowledgment