@confluentinc/kafka-javascript - npm Package Versions

confluent-kafka-javascript v0.2.1

v0.2.1 is a limited availability release. It is supported for all usage.

Features

• Update README, docs, and examples for Confluent's Schema Registry client.

confluent-kafka-javascript v0.2.0

v0.2.0 is a limited availability release. It is supported for all usage.

Features

• Switch to using librdkafka on the latest released tag v2.5.3 instead of master.

confluent-kafka-javascript v0.1.17-devel

v0.1.17-devel is a pre-production, early-access release.

Features

• 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 the sendOffsets method of the transactional producer, and instead, only allow using a consumer.

Fixes

• 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 passing matchConsumerGroupStates as undefined.

confluent-kafka-javascript v0.1.16-devel

v0.1.16-devel is a pre-production, early-access release.

Features

• 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.).

confluent-kafka-javascript v0.1.15-devel

v0.1.15-devel is a pre-production, early-access release.

Features

• Add Node v22 builds and bump librdkafka version on each version bump of this library.

confluent-kafka-javascript v0.1.14-devel

v0.1.14-devel is a pre-production, early-access release.

Features

• 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.

Bug Fixes

• 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.

confluent-kafka-javascript v0.1.13-devel

v0.1.13-devel is a pre-production, early-access release.

Features

• 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.

Bug Fixes

• Fix memory leak in incremental assign (@martijnimhoff, #35).
• Fix various issues with typings, and reconcile typings, JavaScript code, and MIGRATION.md to be consistent.

confluent-kafka-javascript v0.1.12-devel

v0.1.12-devel is a pre-production, early-access release.

Features

• Add support for listTopics in the Admin API.
• Add support for OAUTHBEARER token refresh callback for both promisified and non promisified API.

Bug Fixes

• Fix aliasing bug between NodeKafka::Conf and RdKafka::ConfImpl.
• Fix issue where assign/unassign were called instead of incrementalAssign/incrementalUnassign while using the Cooperative Sticky assigner, and setting the rebalance_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 and RdKafka separate namespaces, while maintaining compatibility with node-rdkafka's type definitions.