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() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.acks.AcknowledgmentCallback |
createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info) |
void |
setCommitTimeout(java.time.Duration commitTimeout) |
public void setCommitTimeout(java.time.Duration commitTimeout)
public org.springframework.integration.acks.AcknowledgmentCallback createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info)
createCallback
in interface org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>