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