- Type Parameters:
K
- the key type.
V
- the value type.
- All Superinterfaces:
- GenericAcknowledgingMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>, KafkaDataListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>
- All Known Implementing Classes:
- BatchMessagingMessageListenerAdapter, FilteringBatchAcknowledgingMessageListenerAdapter
public interface BatchAcknowledgingMessageListener<K,V>
extends GenericAcknowledgingMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>
Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment
handle that recipients can invoke when the message has been processed. The list is
created from the consumer records object returned by a poll.
- Since:
- 1.1
- Author:
- Marius Bogoevici, Gary Russell