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,
org.springframework.kafka.listener.ConsumerProperties consumerProperties)
Construct an instance with the provided properties.
|
| 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, @Nullable org.springframework.kafka.listener.ConsumerProperties consumerProperties)
ackInfo - the ack info.consumerProperties - the consumer properties - only commit-related
properties are used.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.integration.acks.AcknowledgmentCallbackacknowledge in interface org.springframework.integration.acks.SimpleAcknowledgmentacknowledge 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