Skip to content
/ elvan Public

Balanced Kafka (high level) Consumer for ruby binding with librdkafka (v0.9.0.99)

License

Notifications You must be signed in to change notification settings

barockok/elvan

Repository files navigation

Elvan

Usage

require 'elvan'
el = Elvan::RdKafka::Consumer.new(["some-topic-name"], "group.id" => "group-id-name", "bootstrap.servers" => "localhost:9092"})
el.consume do |message, key, offset|
  puts "message : #{message} | key : #{key} | offset : #{offset}"
end

About

Balanced Kafka (high level) Consumer for ruby binding with librdkafka (v0.9.0.99)

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published