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