v0.2.1 is a limited availability release. It is supported for all usage.
- Update README, docs, and examples for Confluent's Schema Registry client.
v0.2.0 is a limited availability release. It is supported for all usage.
- Switch to using
librdkafka
on the latest released tagv2.5.3
instead ofmaster
.
v0.1.17-devel is a pre-production, early-access release.
- Add a commitCb method to the callback-based API which allows committing asynchronously.
- Pass assign/unassign functions to the rebalance callback in the promisified API, allowing the user to control the assignment of partitions, or pause just after a rebalance.
- Remove store from promisified API and let the library handle all the stores.
- Add JavaScript-level debug logging to the client for debugging issues within the binding.
- Various fixes for performance and robustness of the consumer cache.
- Remove
consumerGroupId
argument from thesendOffsets
method of the transactional producer, and instead, only allow using aconsumer
.
- Do not modify RegExps which don't start with a ^, instead, throw an error so that there is no unexpected behaviour for the user (Issue #64).
- Do not mutate arguments in run, pause and resume (Issue #61).
- Fix a segmentation fault in
listGroups
when passingmatchConsumerGroupStates
as undefined.
v0.1.16-devel is a pre-production, early-access release.
- Add per-partition concurrency to consumer.
- Add true
eachBatch
support to consumer. - Add a
leaderEpoch
field to the topic partitions where required (listing, committing, etc.).
v0.1.15-devel is a pre-production, early-access release.
- Add Node v22 builds and bump librdkafka version on each version bump of this library.
v0.1.14-devel is a pre-production, early-access release.
- Add metadata to offset commit and offset store (non-promisified API).
- Add types for logger and loglevel to configuration.
- Add Producer polling from background thread. This improves performance for cases when send is awaited on.
- Enable consume optimization from v0.1.13-devel (Features #2) by default for the promisified API.
- Fix issues with the header conversions from promisified API to the non-promisified API to match the type signature and allow Buffers to be passed as header values in the C++ layer.
v0.1.13-devel is a pre-production, early-access release.
- Add support for
storeOffsets
in the consumer API. - Add optimization while consuming, in cases where the size of messages pending in our subscription is less than the consumer cache size.
- Fix memory leak in incremental assign (@martijnimhoff, #35).
- Fix various issues with typings, and reconcile typings, JavaScript code, and MIGRATION.md to be consistent.
v0.1.12-devel is a pre-production, early-access release.
- Add support for
listTopics
in the Admin API. - Add support for OAUTHBEARER token refresh callback for both promisified and non promisified API.
- Fix aliasing bug between
NodeKafka::Conf
andRdKafka::ConfImpl
. - Fix issue where
assign/unassign
were called instead ofincrementalAssign/incrementalUnassign
while using the Cooperative Sticky assigner, and setting therebalance_cb
as a boolean rather than as a function. - Fix memory leaks in Dispatcher and Conf (both leaked memory at client close).
- Fix type definitions and make
KafkaJS
andRdKafka
separate namespaces, while maintaining compatibility with node-rdkafka's type definitions.
v0.1.11-devel is a pre-production, early-access release.
- Add support for
eachBatch
in the Consumer API (partial support for API compatibility). - Add support for
listGroups
,describeGroups
anddeleteGroups
in the Admin API.
v0.1.10-devel is a pre-production, early-access release.
- Pre-built binaries for Windows (x64) added on an experimental basis.
v0.1.9-devel is a pre-production, early-access release.
- Pre-built binaries for Linux (both amd64 and arm64, both musl and glibc), for macOS (m1), for node versions 18, 20 and 21.
- Promisified API for Consumer, Producer and Admin Client.
- Allow passing topic configuration properties via the global configuration block.
- Remove dependencies with security issues.
- Support for the Cooperative Sticky assignor.