Simple looped consumer for Kafka ruby gem

consumer_loop-kakfa.rb

require 'kafka'

consumer = Kafka::Consumer.new
consumer.loop do |message|
  puts "received"
  message.each do |m|
    #puts "Payload: #{m.payload}, Magic: #{m.magic}, Checksum: #{m.checksum}"
    puts m.payload
  end
end