- Type Parameters:
K
- the key type.
V
- the value type.
- All Superinterfaces:
- GenericAcknowledgingMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>, KafkaDataListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
- All Known Implementing Classes:
- FilteringAcknowledgingMessageListenerAdapter, RecordMessagingMessageListenerAdapter, RetryingAcknowledgingMessageListenerAdapter
public interface AcknowledgingMessageListener<K,V>
extends GenericAcknowledgingMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients
can invoke when the message has been processed.
- Author:
- Marius Bogoevici, Gary Russell