K - the key type.V - the value type.public static class KafkaMessageSource.KafkaAckCallbackFactory<K,V> extends java.lang.Object implements org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>
| Constructor and Description |
|---|
KafkaAckCallbackFactory()
Deprecated.
in favor of
#KafkaAckCallbackFactory(ConsumerProperties). |
KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties) |
| Modifier and Type | Method and Description |
|---|---|
org.springframework.integration.acks.AcknowledgmentCallback |
createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info) |
void |
setCommitTimeout(java.time.Duration commitTimeout)
Deprecated.
in favor of
#KafkaAckCallbackFactory(ConsumerProperties). |
@Deprecated public KafkaAckCallbackFactory()
#KafkaAckCallbackFactory(ConsumerProperties).public KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties)
@Deprecated public void setCommitTimeout(java.time.Duration commitTimeout)
#KafkaAckCallbackFactory(ConsumerProperties).commitTimeout - the commit timeout.public org.springframework.integration.acks.AcknowledgmentCallback createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info)
createCallback in interface org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>