- Fix client socket when closing and error handling #314
- Make
commit()
handle case when only callback is passed #306 - Fix typo in offset.js #304
- Buffer batch for async producers #262
- Add partitions to producer #260
- 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.