org.springframework.integration.kafka.inbound

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

Constructors

Constructor and Description
KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties) Construct an instance with the provided properties.

Method Summary

Modifier and Type	Method and Description
AcknowledgmentCallback	createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info) Create the callback.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaAckCallbackFactory

public KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties)

Construct an instance with the provided properties.

Parameters:

consumerProperties - the properties.

Method Detail

createCallback

public AcknowledgmentCallback createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info)

Description copied from interface: AcknowledgmentCallbackFactory

Create the callback.

Specified by:

createCallback in interface AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>

Parameters:

info - information for the callback to process the acknowledgment.

Returns:

the callback