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)
Deprecated.
in favor of
#KafkaAckCallback(KafkaAckInfo, ConsumerProperties) |
KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo,
org.springframework.kafka.listener.ConsumerProperties consumerProperties)
Construct an instance with the provided properties.
|
KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo,
java.time.Duration commitTimeout)
Deprecated.
in favor of
#KafkaAckCallback(KafkaAckInfo, ConsumerProperties) |
| Modifier and Type | Method and Description |
|---|---|
void |
acknowledge() |
void |
acknowledge(org.springframework.integration.acks.AcknowledgmentCallback.Status status) |
boolean |
isAcknowledged() |
boolean |
isAutoAck() |
void |
noAutoAck() |
@Deprecated public KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo)
#KafkaAckCallback(KafkaAckInfo, ConsumerProperties)ackInfo - the ack info.@Deprecated public KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo, @Nullable java.time.Duration commitTimeout)
#KafkaAckCallback(KafkaAckInfo, ConsumerProperties)ackInfo - the ack info.commitTimeout - the commit timeout.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.kafka.support.Acknowledgmentpublic void noAutoAck()
noAutoAck in interface org.springframework.integration.acks.AcknowledgmentCallbackpublic boolean isAutoAck()
isAutoAck in interface org.springframework.integration.acks.AcknowledgmentCallback