class Kafka::Lite::Producers::Console
Public Class Methods
new(topic)
click to toggle source
Calls superclass method
Producer::new
# File lib/kafka_lite/producers/console.rb, line 6 def initialize(topic) super() @topic = topic end
Private Instance Methods
next_event()
click to toggle source
# File lib/kafka_lite/producers/console.rb, line 13 def next_event if (message = $stdin.gets) Event.new(@topic, 'Message', message: message.chomp) else nil end end