kafka-rb allows you to produce messages to the Kafka distributed publish/subscribe messaging service.
You need to have access to your Kafka instance and be able to connect through TCP. You can obtain a copy and instructions on how to setup kafka at https://github.com/kafka-dev/kafka
sudo gem install kafka-rb
(the code works fine with JRuby, Ruby 1.8x and Ruby 1.9.x)
require 'kafka' producer = Kafka::Producer.new message = Kafka::Message.new("some random message content") producer.send(message)
require 'kafka' producer = Kafka::Producer.new message1 = Kafka::Message.new("some random message content") message2 = Kafka::Message.new("some more content") producer.send([message1, message2])
require 'kafka' producer = Kafka::Producer.new producer.batch do |messages| puts "Batching a send of multiple messages.." messages << Kafka::Message.new("first message to send") messages << Kafka::Message.new("second message to send") end
require 'kafka' consumer = Kafka::Consumer.new messages = consumer.consume
require 'kafka' consumer = Kafka::Consumer.new consumer.loop do |messages| puts "Received" puts messages end
Contact for questions
alejandrocrosa at(@) gmail.com