v1.7.0

v1.7.0 is a feature release. It is supported for all usage.

Enhancements

1. References librdkafka v2.12.1. Refer to the librdkafka v2.12.1 release notes for more information.
2. Configurable batch size through the js.consumer.max.batch.size property
   and cache size through the js.consumer.max.cache.size.per.worker.ms
   property (#393).
3. Statistics callback now available when using the promisified API with all
   client types (#399).
4. Fix for at-least-once guarantee not ensured in case a seek happens on one
   partition and there are messages being fetched about other partitions (#393).
5. Avoid returning a negative lag in case there is no cached offset for
   the HWM (#406).

v1.7.0-rc1

v1.7.0-rc1 is a release candidate feature release. It's not supported.

Enhancements

1. Avoid returning a negative lag in case there is no cached offset for the HWM (#406).

v1.7.0-alpha.1

v1.7.0-alpha.1 is an alpha feature release. It's not supported.

Enhancements

1. References librdkafka v2.12.1. Refer to the librdkafka v2.12.1 release notes for more information.
2. Statistics callback now available when using the promisified API with all
   client types (#399).

v1.6.1-alpha.1

v1.6.1 is an alpha maintenance release. It's not supported.

Enhancements

1. Configurable batch size through the js.consumer.max.batch.size property (#389).
2. Fix for at-least-once guarantee not ensured in case a seek happens on one
   partition and there are messages being fetched about other partitions (#393).

v1.6.0

v1.6.0 is a feature release. It is supported for all usage.

Enhancements

1. References librdkafka v2.12.0. Refer to the librdkafka v2.12.0 release notes for more information.
2. OAuth OIDC method example for Kafka metadata based authentication with
   an Azure IMDS endpoint using an attached managed identity as principal (#377).

v1.6.0-rc4: Update version to 1.6.0-rc4 (#383)

Pre release of v1.6.0

v1.5.0

v1.5.0 is a feature release. It is supported for all usage.

Enhancements

1. Adds support for highWatermark, offsetLag(), and offsetLagLow() in eachBatch callback (#317).

Fixes

1. Fix issue of delay of up to 5s in receiving messages after pause and resume, or seek (#285, #363).

v1.5.0-rc1

Release candidate for v1.5.0.

v1.4.1

v1.4.1 is a maintenance release. It is supported for all usage.

Enhancements

1. References librdkafka v2.11.1. Refer to the librdkafka v2.11.1 release notes for more information.

v1.4.1-rc2

Release candidate for v1.4.1