Name: kafka-rb
Owner: Librato
Description: A simple Producer/Consumer client for Kafka (a distributed publish/subscribe messaging service)
Forked from: mheffner/kafka-rb
Created: 2017-04-17 17:42:49.0
Updated: 2017-04-17 17:42:51.0
Pushed: 2017-04-17 17:58:13.0
Size: 94
Language: Ruby
GitHub Committers
User | Most Recent Commit | # Commits |
---|
Other Committers
User | Most Recent Commit | # Commits |
---|
kafka-rb allows you to produce and consume messages to / from the Kafka distributed messaging service. This is an improved version of the original Ruby client written by Alejandro Crosa, and is used in production at wooga.
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 http://incubator.apache.org/kafka/
sudo gem install kafka-rb
(should work fine with JRuby, Ruby 1.8 and 1.9)
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
alejandrocrosa at(@) gmail.com http://twitter.com/alejandrocrosa
tim.lossen@wooga.net