public class DefaultAcknowledgment extends java.lang.Object implements Acknowledgment
Acknowledgment that defers to an underlying
OffsetManager.| Constructor and Description |
|---|
DefaultAcknowledgment(OffsetManager offsetManager,
KafkaMessage message) |
DefaultAcknowledgment(OffsetManager offsetManager,
Partition partition,
java.lang.Long offset) |
| Modifier and Type | Method and Description |
|---|---|
void |
acknowledge()
Invoked when the message for which the acknowledgment has been created has been processed.
|
public DefaultAcknowledgment(OffsetManager offsetManager, Partition partition, java.lang.Long offset)
public DefaultAcknowledgment(OffsetManager offsetManager, KafkaMessage message)
public void acknowledge()
Acknowledgmentacknowledge in interface Acknowledgment