Interface GenericMessageListener<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods Default Methods 
      Modifier and Type Method Description
      void onMessage​(T data)
      Invoked with data from kafka.
      default void onMessage​(T data, org.apache.kafka.clients.consumer.Consumer<?,​?> consumer)
      Invoked with data from kafka and provides access to the Consumer.
      default void onMessage​(T data, Acknowledgment acknowledgment)
      Invoked with data from kafka.
      default void onMessage​(T data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,​?> consumer)
      Invoked with data from kafka and provides access to the Consumer.
    • Method Detail

      • onMessage

        void onMessage​(T data)
        Invoked with data from kafka.
        Parameters:
        data - the data to be processed.
      • onMessage

        default void onMessage​(T data,
                               Acknowledgment acknowledgment)
        Invoked with data from kafka. The default implementation throws UnsupportedOperationException.
        Parameters:
        data - the data to be processed.
        acknowledgment - the acknowledgment.
      • onMessage

        default void onMessage​(T data,
                               org.apache.kafka.clients.consumer.Consumer<?,​?> consumer)
        Invoked with data from kafka and provides access to the Consumer. The default implementation throws UnsupportedOperationException.
        Parameters:
        data - the data to be processed.
        consumer - the consumer.
        Since:
        2.0
      • onMessage

        default void onMessage​(T data,
                               Acknowledgment acknowledgment,
                               org.apache.kafka.clients.consumer.Consumer<?,​?> consumer)
        Invoked with data from kafka and provides access to the Consumer. The default implementation throws UnsupportedOperationException.
        Parameters:
        data - the data to be processed.
        acknowledgment - the acknowledgment.
        consumer - the consumer.
        Since:
        2.0