I'm about to start adding ZooKeeper support, but first I wanted to make sure all specs pass. One didn't (the one I created earlier), so this aims to fix it. I have tested it with 1.8.7, 1.9.2 and JRuby.
Moved encoding declaration to the top, where it is actually used by ruby
Fix failing spec - force UTF8 encoding on ruby 1.9+. Specs now pass w…
…ith 1.8.7, 1.9.2 and JRuby
Added zookeeper gem dependency
Added consumer and group id
Added ConsumerRegistry and the register method
What is the state of adding zookeeper to the Ruby Consumers?
I am looking into using Kafka with Ruby, but I need to have the ability to create consumer groups so that only one consumer in a group receives a message.
I'm wondering about Zookeeper support as well :)
I'm also wondering about zookeeper support. Thanks!