Class MyListener

  • All Implemented Interfaces:
    GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,​java.lang.String>>, MessageListener<java.lang.String,​java.lang.String>

    public class MyListener
    extends java.lang.Object
    implements MessageListener<java.lang.String,​java.lang.String>
    MessageListener for dynamic containers.
    Since:
    2.8.9
    Author:
    Gary Russell
    • Constructor Summary

      Constructors 
      Constructor Description
      MyListener()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onMessage​(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,​java.lang.String> data)
      Invoked with data from kafka.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • MyListener

        public MyListener()
    • Method Detail

      • onMessage

        public void onMessage​(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,​java.lang.String> data)
        Description copied from interface: GenericMessageListener
        Invoked with data from kafka.
        Specified by:
        onMessage in interface GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,​java.lang.String>>
        Parameters:
        data - the data to be processed.