hermann
hermann copied to clipboard
A gem providing cross-platform Kafka producer and consumer support
After installing the Hermann gem on a clean Ubuntu LTS box, I get the following error when using Hermann from a simple producer test: ``` ruby: symbol lookup error: /home/HOME/.rbenv/versions/2.1.3/lib/ruby/gems/2.1.0/gems/hermann-0.24.1.dev/ext/hermann/hermann_lib.so:...
I think with the recent work from @jakesandlund and @osheroff we've been bringing the `Producer` and `Consumer` APIs into parity and simplifying things a bit. I'd like to push towards...
I'm running hermann consumer on MRI 2.3.0 and it crashes with the following error: ``` ruby: symbol lookup error: /app/vendor/bundle/ruby/2.3.0/gems/hermann0.26.1.0/ext/hermann/hermann_rdkafka.so: undefined symbol: inflateInit2_ ``` I'm running this code on a...
Right now it throws the zookeepers parameter away https://github.com/lookout/Hermann/blob/master/lib/hermann/consumer.rb#L37
The Consumer API was modified with changes required by the JavaSimpleConsumer.
Create java based consumer: - non blocking, can specify multiple threads - supports multiple topics and streams - takes in custom consumer worker classes Currently, the JavaSimpleConsumer doesn't support these...
As of now error messages are puts to STDOUT. These messages should probably be logged.
This code below was executed while kafka service was shut down. No failure is returned, promise was fulfilled and on_success has been called which seems wrong! ``` [45] pry(main)> producer...
Currently, there is very little client side configuration for Hermann, and by extension librdkafka. For example, I'm running into an issue where I'd love to edit 'queue.buffering.max.messages', but lack the...