Interface IMessageHandler


  • public interface IMessageHandler
    Our interface for handling messages received by the consumer. Used to decouple the Kafka consumer from the database persistence logic
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void close()
      Close any resources held by the handler
      void process​(java.util.List<java.lang.String> messages)
      Ask the handler to process the list of messages.
    • Method Detail

      • close

        void close()
        Close any resources held by the handler