class Kafka::Lite::Consumers::Console

Public Class Methods

new(topic) click to toggle source
Calls superclass method Consumer::new
# File lib/kafka_lite/consumers/console.rb, line 6
def initialize(topic)
  super('CONSOLE_CONSUMER', topic)
end

Private Instance Methods

process(event) click to toggle source
# File lib/kafka_lite/consumers/console.rb, line 12
def process event
  $stdout.puts event
  $stdout.flush
end