- Deps: upgrade snappy to 3.2.0
- Zookeeper#listConsumers: ignore error when there is no such node in zookeeper
- Fix: add callback to consumer.autoCommit method #198
- Emit an error when there is a problem with the socket connection to the kafka broker #196
- Fix: emit the error instead of slient swallow it #193
- Typo in error message #189
- Bump deps
- Refresh metadata after auto rebalance among brokers #180
- Initialize partition owner with consumerId #178
- Fix #175: Refresh topic metadata in Producer when broker change
- Refactor Client#refreshMetadata method
- Add the missing semicolons, no offense, just keep style.
- Fix #170: In case of
offsetOutOfRange
, the consumer should be paused. - Fix #169: When paused why try to fetch every 1000 ms?
- Ref: remove unused variables.