Package org.springframework.kafka.listener.adapter

Interface BatchToRecordAdapter.Callback<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type.
    Enclosing interface:
    BatchToRecordAdapter<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 static interface BatchToRecordAdapter.Callback<K,​V>
    A callback for each message.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void invoke​(org.apache.kafka.clients.consumer.ConsumerRecord<K,​V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,​?> consumer, org.springframework.messaging.Message<?> message)
      Handle each message.

    • Method Detail

      • invoke

        void invoke​(org.apache.kafka.clients.consumer.ConsumerRecord<K,​V> record,
            Acknowledgment ack,
            org.apache.kafka.clients.consumer.Consumer<?,​?> consumer,
            org.springframework.messaging.Message<?> message)
        Handle each message.
        Parameters:
        record - the record.
        ack - the acknowledgment.
        consumer - the consumer.
        message - the message.