v2.1.0

Minor release

1. Upgraded librdkafka to 0.11.1

Consumer Changes

1. Partition EOF will no longer stop a batch from completing when consuming.

v2.0.0

Major release because there are breaking changes!

Breaking Changes

1. Keys are now returned as buffers in delivery reports
2. Keys are now produced as buffers. If you pass one in as a string it will be converted.
3. Topic objects have been removed. You should use topic name strings to create topics.

• New librdkafka produce methods do not support topic objects because they are in the process of being removed.
• You should use topic configuration to configure topics, and separate producers if special cases are needed. Producers are cheap!

v1.0.6

New release version v1.0.5.

Root Object Changes

1. Added librdkafkaVersion and features properties to root object.

Consumer Changes

1. assign and unassign in the rebalance callback check if the consumer is connected before they throw.

v1.0.5

New release version v1.0.5. This release note includes changes from v1.0.2 - v1.0.5

Consumer Changes

1. Bug fix for custom rebalance callbacks where assignments were not being set. (v1.0.5)
2. Kafka read stream now supports streamAsBatch option, if it is running in objectMode. This will push arrays to the stack instead of individual messages. (v1.0.4)
3. Fixed callback "leak" in read stream under high message volume (v1.0.3)

v1.0.1

New release version v1.0.1

Producer Changes

1. Passing a buffer as a key will not convert it to a string before sending it to Kafka

v1.0.0

New release version v1.0.0

Producer API Changes

1. Producer write stream is now its own class that has its own producer. Producer methods can be accessed through the member variable.

• Create one by using Producer.createWriteStream();

Consumer API Changes

1. Added offset_commit_cb
2. Rebalance callback now has first parameter as an error object. The error object can be checked to see if it is an assignment or an unassignment
3. Consumer write stream is now its own class that has its own consumer. Consumer methods can be accessed through the member variable.

• Create one by using Consumer.createReadStream()

4. Added query_watermark_offsets support
5. Added support for seek method, but currently not supported in librdkafka 0.9.5. Will likely be in next release.

v0.10.2

New release version v0.10.2

Producer API Changes

1. Producer flush method now is called asynchronously and must be provided a callback.

v0.10.10

New release version v0.10.0

API Changes

1. error event is renamed event.error to show it corresponds with errors reported by the librdkafka internals. Only streams emit events named error now, when there are stream related errors.
2. Added new error codes for librdkafka.

Consumer API Changes

1. commit asynchronous methods no longer take a callback, and instead map directly to the librdkafka async commit variants.
2. Internal queue timeouts no longer considered error worthy for consume methods.

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.