Package org.springframework.kafka.listener

Interface BatchAcknowledgingMessageListener<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type.
    All Superinterfaces:
    BatchMessageListener<K,​V>, GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,​V>>>
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    @FunctionalInterface
public interface BatchAcknowledgingMessageListener<K,​V>
extends BatchMessageListener<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

    • Method Detail

      • onMessage

        default void onMessage​(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,​V>> data)
        Invoked with data from kafka. Containers should never call this since it they will detect that we are an acknowledging listener.
        Specified by:
        onMessage in interface GenericMessageListener<K>
        Parameters:
        data - the data to be processed.

      • onMessage

        void onMessage​(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,​V>> data,
               Acknowledgment acknowledgment)
        Description copied from interface: GenericMessageListener
        Invoked with data from kafka. The default implementation throws UnsupportedOperationException.
        Specified by:
        onMessage in interface GenericMessageListener<K>
        Parameters:
        data - the data to be processed.
        acknowledgment - the acknowledgment.