All pull requests

Pull requests

• Integrate Schema Registry serdes into the KafkaJS producer and consumer

  #543·Emanuele Sabellico (emasab) opened Sep 23, 2026·

  ·
  8

• Retry connect() on transient errors (KafkaJS compatibility)

  #542·Pranav Rathi (pranavrth) opened Sep 23, 2026·

  ·
  20

• Fix: segfault in consumer loop due to use after free in workers thread

  #541·Constantin Dimitrov (constantind) opened Sep 23, 2026·

  ·
  1

• Fix npm audit vulnerabilities in dev dependencies

  #540·Pranav Rathi (pranavrth) opened Sep 22, 2026·

  ·
  2

• fix(kafkajs): map maxBytes to fetch.max.bytes instead of a per-partition alias

  status:planned
  #539·Soroka Anton (uginroot) opened Sep 15, 2026·

  ·
  1

  

• Update dependency js-yaml to v4.3.2 [SECURITY] (master)

  renovatebot-cve
  #538·renovatebot-confluentinc[bot] opened Sep 13, 2026·

  ·
  1

• [Typescript] Pass errors to loggers

  #537·Gabe Gorelick (gabegorelick) opened Sep 11, 2026·

  ·
  1

  4

• Add describeCluster to the Admin API

  enhancement
  #530·Huy, Tae Young (kty1965) opened Sep 1, 2026·

  ·
  1

• Add s390x (IBM Z) release and post-install support

  #527·Devarsh Patel (Devarsh010) opened Aug 31, 2026·

  ·
  5

• Add Variant, Decimal, and Timestamp CEL functions

  #524·Robert Yokota (rayokota) opened Aug 24, 2026·

  ·
  96

• fix: track last consumed offset in eachBatch resolveOffset so pause() does not lose prefetched messages

  #518·eqcu opened Jul 30, 2026·

  ·
  1

• Update node-tar package minor version to .19

  #513·Benjamin (chooklii) opened Jul 21, 2026·

  ·

• Prebuild binaries for Node 25 and 26

  #512·Leo Singer (lpsinger) opened Jul 20, 2026·

  ·
  4

• Pass connection metadata timeout config to connect() in KafkaJS

  #510·Nuno Pires (nunopi) opened Jul 17, 2026·

  ·

• Add partition to HighLevelProducer callback

  #506·Dustin (GiHoon1123) opened Jul 6, 2026·

  ·
  1

  1

• [Typescript] Improve types for isKafkaJSError

  #498·Leo Singer (lpsinger) opened Jun 23, 2026·

  ·

• fix(types): expose cooperative-sticky rebalance methods on KafkaConsumer

  #485·Dvir Arad (dvirarad) opened May 11, 2026·

  ·
  1

  1

• Migrate from NAN to N-API

  #471·James Sigurdarson (jamiees2) opened Mar 17, 2026·

  ·
  16

• feat: expose cluster ID via getClusterId() and describeCluster()

  #451·robcarlan-datadog opened Feb 19, 2026·

  ·

• Remove bluebird in favor of native Promise

  #450·koooge (koooge) opened Feb 19, 2026·

  ·

• WARNING: MAJOR (BREAKING) CHANGE: Update dependency @eslint/js to v10 (master)

  #449·renovatebot-confluentinc[bot] opened Feb 18, 2026·

  ·
  2

• [Typescript] fix(schemaregistry): add support for format to validation

  component:schema-registry
  #443·Jonathan Arnold (mixnblend) opened Feb 13, 2026·

  ·
  8

• WARNING: MAJOR (BREAKING) CHANGE: Update dependency @smithy/types to v4 (master)

  #441·renovatebot-confluentinc[bot] opened Feb 9, 2026·

  ·
  1

• Fix CompressionTypes.Snappy naming for KafkaJS compatibility

  #433·Vladimir Zhdanov (VLZH) opened Jan 23, 2026·

  ·

• Performance test improvements

  #394·Emanuele Sabellico (emasab) opened Oct 29, 2025·

  ·
  7