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) |
public org.springframework.integration.acks.AcknowledgmentCallback createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info)
createCallback in interface org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>