phobos-handler-hooks-example.rb

class MyHandler
  include Phobos::Handler
  
  def self.start(kafka_client)
    # setup handler
  end

  def self.stop
    # teardown
  end

  def self.around_consume(payload, metadata)
    Phobos.logger.info "consuming..."
    output = yield
    Phobos.logger.info "done, output: #{output}"
  end

  def consume(payload, metadata)
    # consume or skip message
  end
end