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()
Acknowledgment
acknowledge
in interface Acknowledgment