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:
AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,
V>>
- Enclosing class:
- KafkaMessageSource<K,
V>
public static class KafkaMessageSource.KafkaAckCallbackFactory<K,V>
extends Object
implements AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>
AcknowledgmentCallbackFactory for KafkaAckInfo.
-
Constructor Summary
ConstructorsConstructorDescriptionKafkaAckCallbackFactory
(org.springframework.kafka.listener.ConsumerProperties consumerProperties) Construct an instance with the provided properties. -
Method Summary
Modifier and TypeMethodDescriptionCreate the callback.
-
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
Description copied from interface:AcknowledgmentCallbackFactory
Create the callback.- Specified by:
createCallback
in interfaceAcknowledgmentCallbackFactory<K>
- Parameters:
info
- information for the callback to process the acknowledgment.- Returns:
- the callback
-