Package org.springframework.kafka.listener

Interface BatchConsumerAwareMessageListener<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>>>
    All Known Implementing Classes:
    AggregatingReplyingKafkaTemplate
    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 BatchConsumerAwareMessageListener<K,​V>
extends BatchMessageListener<K,​V>
    Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll. Access to the Consumer is provided.
    Since:
    2.0
    Author:
    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 a consumer aware 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,
               org.apache.kafka.clients.consumer.Consumer<?,​?> consumer)
        Description copied from interface: GenericMessageListener
        Invoked with data from kafka and provides access to the Consumer. The default implementation throws UnsupportedOperationException.
        Specified by:
        onMessage in interface GenericMessageListener<K>
        Parameters:
        data - the data to be processed.
        consumer - the consumer.