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