v1.0.0
New release version v1.0.0
Producer API Changes
- 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
- Added
offset_commit_cb
- 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
- 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()
- Added
query_watermark_offsets
support - Added support for seek method, but currently not supported in librdkafka 0.9.5. Will likely be in next release.