Class KafkaMessageSource.KafkaAckCallbackFactory<K,V>
java.lang.Object
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory<K,V>
- Type Parameters:
K- the key type.V- the value type.
- All Implemented Interfaces:
org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>
- Enclosing class:
- KafkaMessageSource<K,V>
public static class KafkaMessageSource.KafkaAckCallbackFactory<K,V> extends java.lang.Object implements org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>
AcknowledgmentCallbackFactory for KafkaAckInfo.
-
Constructor Summary
Constructors Constructor Description KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties)Construct an instance with the provided properties. -
Method Summary
Modifier and Type Method Description org.springframework.integration.acks.AcknowledgmentCallbackcreateCallback(KafkaMessageSource.KafkaAckInfo<K,V> info)
-
Constructor Details
-
KafkaAckCallbackFactory
public KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties)Construct an instance with the provided properties.- Parameters:
consumerProperties- the properties.
-
-
Method Details
-
createCallback
public org.springframework.integration.acks.AcknowledgmentCallback createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info)- Specified by:
createCallbackin interfaceorg.springframework.integration.acks.AcknowledgmentCallbackFactory<K>
-