K
- the key type.V
- the value type.public static class KafkaMessageSource.KafkaAckCallback<K,V>
extends java.lang.Object
implements org.springframework.integration.acks.AcknowledgmentCallback, org.springframework.kafka.support.Acknowledgment
Constructor and Description |
---|
KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge() |
void |
acknowledge(org.springframework.integration.acks.AcknowledgmentCallback.Status status) |
boolean |
isAcknowledged() |
boolean |
isAutoAck() |
void |
noAutoAck() |
public KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo)
public void acknowledge(org.springframework.integration.acks.AcknowledgmentCallback.Status status)
acknowledge
in interface org.springframework.integration.acks.AcknowledgmentCallback
public boolean isAcknowledged()
isAcknowledged
in interface org.springframework.integration.acks.AcknowledgmentCallback
public void acknowledge()
acknowledge
in interface org.springframework.kafka.support.Acknowledgment
public void noAutoAck()
noAutoAck
in interface org.springframework.integration.acks.AcknowledgmentCallback
public boolean isAutoAck()
isAutoAck
in interface org.springframework.integration.acks.AcknowledgmentCallback