v0.9.0

New release version v0.9.0

Consumer API Changes

1. commit synchronous methods now throw errors in a similar pattern as the other throwable methods. They will be full librdkafka error objects with error codes, etc. Asynchronous methods are unchanged, as they return error objects in the callback.

Bug fixes

1. Bug with this binding in producer write stream in previously published (now unpublished) version has been fixed.

v0.8.2

New release version v0.8.2

Producer API Changes

1. Added new producer method, setPollInterval(interval). If you simply want to poll for events on an interval, you can pass it here without needing to manage connections or disconnections.
2. Fixed some bugs that would be related to manually connecting/disconnecting when using the producer stream.
3. Producer stream now only uses topic objects if topic options are provided.

Consumer API Changes

1. Added new consumer methods, commitMessage and commitMessageSync. When committing a message instead of a topic partition, these methods will commit the proper offsets instead of the off-by-one issue seen prior.

v0.8.0

New release version v0.8.0

API Changes

1. Produce method now supports sending a timestamp, which is permitted by broker version >= 0.10
   • A side effect of this change is that the opaque parameter has now moved one to the right.
2. Recommended way to pass a topic is now as a string
   • RdKafka topic objects are now created and destroyed on use so they no longer stop disconnection or deadlock threads while they are waiting to be garbage collected (potential issue). Passing topics as a string avoids this issue. You can still pass topic objects if you need custom config, but there is a performance hit (~10% in most cases).
3. dr_cb and dr_msg_cb now properly support NULL vs. empty payloads in delivery reports.
4. Producer.poll must now be called manually. Previously it was being called every time a message was produced, which was a gigantic waste of time and made produce block on occasion.

Under the hood changes

1. librdkafka upgraded to 0.9.4.
   • https://github.com/edenhill/librdkafka/releases/tag/v0.9.4
2. RW locks to make sure produce method no longer blocks.

v0.6.0

Changes:

1. Producer produce is now a synchronous method that does not do Object enumeration to read its parameters.
2. Graceful shutdown fixes due to changes in memory allocation in C++
3. Various performance passes
4. Mocha-ized end to end unit tests.
5. Refactoring of C++ code to reduce number of unnecessary classes.