confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

Stars: 304
Forks: 45
Open beginner issues: 0
Indexed issues: 79
Avg merge: 11h 47m
Merged PRs (30d): 5

Dominant language: TypeScript
License: MIT
Last GitHub push: Sep 11, 2026
Latest indexed: Sep 15, 2026
Contributing guide: Contributing guide
Code of conduct: No code of conduct
Beginner labels: good first issue

Open All

79 open issues indexed

Deprecated dependencies (inflight, glob, rimraf) used by @confluentinc/kafka-javascript Open

confluentinc/confluent-kafka-javascript#345 · 2 comments · 3 reactions · 0 assignees · Indexed Sep 15, 2026
Does createPartitioner property supports custom methods in confluent-kafka-javascript client ? Open

question

confluentinc/confluent-kafka-javascript#349 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Clarification on documentation: "eachBatch’s batch size never exceeds 1.*" Open

documentation question

confluentinc/confluent-kafka-javascript#350 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
uncommittedOffsets : Clarification and Alternatives Open

question

confluentinc/confluent-kafka-javascript#351 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Using package in electron Open

status:waiting-for-interest

confluentinc/confluent-kafka-javascript#361 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Disconnected Consumers Continue To Take Up Space in Heap Open

confluentinc/confluent-kafka-javascript#369 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 15, 2026
fix moduleName to support npm config/mirrors Open

status:waiting-for-interest

confluentinc/confluent-kafka-javascript#372 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
segmentation fault on fetchOffsets for unseen groups Open

librdkafka

confluentinc/confluent-kafka-javascript#374 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
admin.connect() (Promisified API) does nothing useful Open

confluentinc/confluent-kafka-javascript#376 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
unknown format "email" ignored in schema at path Open

component:schema-registry

confluentinc/confluent-kafka-javascript#387 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
RFE: Kafka Streams support Open

enhancement status:waiting-for-interest

confluentinc/confluent-kafka-javascript#391 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Missing Node.js v26 prebuilts Open

enhancement status:planned

confluentinc/confluent-kafka-javascript#397 · 12 comments · 14 reactions · 0 assignees · Indexed Sep 15, 2026
pause() during graceful shutdown corrupts committed offsets causing message reprocessing Open

confluentinc/confluent-kafka-javascript#404 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Bug: #clearCacheAndResetPositions seeks to wrong offset causing message duplication Open

confluentinc/confluent-kafka-javascript#417 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
5 security issues in the dependencies of @confluentinc/schemaregistry (high vulnerability) Open

component:schema-registry

confluentinc/confluent-kafka-javascript#429 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
PARTCNT change to zero and consuming stops after broker issue Open

confluentinc/confluent-kafka-javascript#430 · 0 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
admin.describeConfigs Open

component:admin

confluentinc/confluent-kafka-javascript#444 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Cross-topic blocking still present in v1.8.2 (related to #247) Open

confluentinc/confluent-kafka-javascript#468 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 15, 2026
No type available for cooperative-sticky re-balance Open

consumer typescript

confluentinc/confluent-kafka-javascript#469 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Long running message processing and rebalances Open

confluentinc/confluent-kafka-javascript#472 · 0 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Building confluent-kafka-javascript on Linux ppc64le is failing Open

installation

confluentinc/confluent-kafka-javascript#473 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Consumer silently stops consuming — race conditions in #nonEmpty and #fetchInProgress signals Open

confluentinc/confluent-kafka-javascript#476 · 7 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
eachBatch: fatal/unrecoverable consumer errors (e.g. ERR__STATE) are swallowed — consumer wedges silently with no crash event or run() rejection Open

confluentinc/confluent-kafka-javascript#497 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
kafkaJS consumer: maxBytesPerPartition is silently overridden by maxBytes default Open

confluentinc/confluent-kafka-javascript#511 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add KIP-932 Share Consumer support Open

status:planned

confluentinc/confluent-kafka-javascript#514 · 0 comments · 1 reaction · 1 assignee · Indexed Sep 15, 2026
KafkaJS compat: pause() on an eachBatch consumer permanently loses prefetched messages (consumption wedges) Open

status:under-review status:waiting-for-interest

confluentinc/confluent-kafka-javascript#517 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
eachBatch: cache expiration discards already-fetched, undelivered records and skips the position rewind → silent message loss Open

confluentinc/confluent-kafka-javascript#528 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Admin API: support describeCluster() Open

enhancement status:planned

confluentinc/confluent-kafka-javascript#529 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Segfault (strlen on NULL) in admin.describeGroups() when brokers are unreachable — unguarded NewFromUtf8 in FromConsumerGroupDescription Open

confluentinc/confluent-kafka-javascript#531 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026

A short digest of beginner-friendly GitHub issues.