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.AcknowledgmentCallbackpublic boolean isAcknowledged()
isAcknowledged in interface org.springframework.integration.acks.AcknowledgmentCallbackpublic void acknowledge()
acknowledge in interface org.springframework.kafka.support.Acknowledgmentpublic void noAutoAck()
noAutoAck in interface org.springframework.integration.acks.AcknowledgmentCallbackpublic boolean isAutoAck()
isAutoAck in interface org.springframework.integration.acks.AcknowledgmentCallback