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.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