npmpackage.info

Gathering detailed insights and metrics for kafkajs

Other packages similar to kafkajs

@opentelemetry/instrumentation-kafkajs

0.12.0

OpenTelemetry instrumentation for `kafkajs` messaging client for Apache Kafka

@kafkajs/confluent-schema-registry

3.9.0

ConfluentSchemaRegistry is a library that makes it easier to interact with the Confluent schema registry, it provides convenient methods to encode, decode and register new schemas using the Apache Avro serialization format.

opentelemetry-instrumentation-kafkajs

0.41.0

open telemetry instrumentation for the `kafkajs` kafka client

kafkajs-snappy

1.1.0

Snappy codec for KafkaJS

Gathering detailed insights and metrics for kafkajs

kafkajs - 2.2.4 | npmpackage.info

kafkajs

A modern Apache Kafka client for node.js

2.2.4

3,887

MIT

JavaScript

714.96 kB

3.4

Installations

npm install kafkajs

Developer Guide

BETA

Typescript

Yes

Module System

CommonJS

Min. Node Version

>=14.0.0

Node Version

14.21.3

NPM Version

6.14.18 Pull Requests

Open

43

Total

750

Closed

123

Merged

584

Issues

Open

343

Total

1,006

Closed

663

Releases

v2.2.4

Updated on Feb 27, 2023

v2.2.3

Updated on Nov 21, 2022

v2.2.2

Updated on Oct 18, 2022

v2.2.1

Updated on Oct 13, 2022

v2.2.0

Updated on Aug 16, 2022

v2.1.0

Updated on Jun 28, 2022

View All 46 releases

Languages

JavaScript

Shell

TypeScript

Java

CSS

JavaScript (98.33%)

Shell (0.87%)

TypeScript (0.55%)

Java (0.14%)

CSS (0.11%)

Developer

tulios

Download Statistics

Total Downloads

Last Day

Last Week

Last Month

Last Year

GitHub Statistics

MIT License

3,887 Stars

3,097 Commits

561 Forks

36 Watchers

27 Branches

116 Contributors

Updated on Jul 11, 2025

Maintainers

View All 116 Contributors

Package Meta Information

Latest Version

2.2.4

Package Id

kafkajs@2.2.4

Unpacked Size

714.96 kB

Size

143.73 kB

File Count

391

NPM Version

6.14.18

Node Version

14.21.3

Published on

Feb 27, 2023

Total Downloads

Cumulative downloads

Total Downloads

NaN

Last Day

NaN

Compared to previous day

Last Week

NaN

Compared to previous week

Last Month

NaN

Compared to previous month

Last Year

NaN

Compared to previous year

Weekly Downloads

Monthly Downloads

Yearly Downloads

KafkaJS

A modern Apache Kafka® client for Node.js
Get Started »

Read the Docs · Report Bug · Request Feature

About the project
Contributing
- Help Wanted
- Contact
License
- Acknowledgements

About the Project

KafkaJS is a modern Apache Kafka client for Node.js. It is compatible with Kafka 0.10+ and offers native support for 0.11 features.

KAFKA is a registered trademark of The Apache Software Foundation and has been licensed for use by KafkaJS. KafkaJS has no affiliation with and is not endorsed by The Apache Software Foundation.

Sponsors ❤️

Upstash: Serverless Kafka

True Serverless Kafka with per-request-pricing
Managed Apache Kafka, works with all Kafka clients
Built-in REST API designed for serverless and edge functions
Start for free in 30 seconds!

Get help directly from a KafkaJS developer

Become a Github Sponsor to have a video call with a KafkaJS developer
Receive personalized support, validate ideas or accelerate your learning
Save time and get productive sooner, while supporting KafkaJS!
See support options!

To become a sponsor, reach out in our Slack community to get in touch with one of the maintainers. Also consider becoming a Github Sponsor by following any of the links under "Sponsor this project" in the sidebar.

Features

Producer
Consumer groups with pause, resume, and seek
Transactional support for producers and consumers
Message headers
GZIP compression
- Snappy, LZ4 and ZSTD compression through pluggable codecs
Plain, SSL and SASL_SSL implementations
Support for SCRAM-SHA-256 and SCRAM-SHA-512
Support for AWS IAM authentication
Admin client

Getting Started

1npm install kafkajs
2# yarn add kafkajs

Usage

1const { Kafka } = require('kafkajs')
2
3const kafka = new Kafka({
4  clientId: 'my-app',
5  brokers: ['kafka1:9092', 'kafka2:9092']
6})
7
8const producer = kafka.producer()
9const consumer = kafka.consumer({ groupId: 'test-group' })
10
11const run = async () => {
12  // Producing
13  await producer.connect()
14  await producer.send({
15    topic: 'test-topic',
16    messages: [
17      { value: 'Hello KafkaJS user!' },
18    ],
19  })
20
21  // Consuming
22  await consumer.connect()
23  await consumer.subscribe({ topic: 'test-topic', fromBeginning: true })
24
25  await consumer.run({
26    eachMessage: async ({ topic, partition, message }) => {
27      console.log({
28        partition,
29        offset: message.offset,
30        value: message.value.toString(),
31      })
32    },
33  })
34}
35
36run().catch(console.error)

Learn more about using KafkaJS on the official site!

Read something on the website that didn't work with the latest stable version?
Check the pre-release versions - the website is updated on every merge to master.

Contributing

KafkaJS is an open-source project where development takes place in the open on GitHub. Although the project is maintained by a small group of dedicated volunteers, we are grateful to the community for bug fixes, feature development and other contributions.

See Developing KafkaJS for information on how to run and develop KafkaJS.

Help wanted 🤝

We welcome contributions to KafkaJS, but we also want to see a thriving third-party ecosystem. If you would like to create an open-source project that builds on top of KafkaJS, please get in touch and we'd be happy to provide feedback and support.

Here are some projects that we would like to build, but haven't yet been able to prioritize:

Dead Letter Queue - Automatically reprocess messages
✅ Schema Registry - Now available! thanks to @erikengervall
Metrics - Integrate with the instrumentation events to expose commonly used metrics

Contact 💬

Join our Slack community

License

See LICENSE for more details.

Acknowledgements

Thanks to Sebastian Norde for the V1 logo ❤️
Thanks to Tracy (Tan Yun) for the V2 logo ❤️

Apache Kafka and Kafka are either registered trademarks or trademarks of The Apache Software Foundation in the United States and other countries. KafkaJS has no affiliation with the Apache Software Foundation.

No vulnerabilities found.

10

Dangerous-Workflow

Determines if the project's GitHub Action workflows avoid dangerous patterns.

10

License

Determines if the project has defined a license.

10

Binary-Artifacts

Determines if the project has generated executable (binary) artifacts in the source repository.

6

Code-Review

Determines if the project requires human code review before pull requests (aka merge requests) are merged.

0

Maintained

Determines if the project is "actively maintained".

0

Token-Permissions

Determines if the project's workflows follow the principle of least privilege.

0

CII-Best-Practices

Determines if the project has an OpenSSF (formerly CII) Best Practices Badge.

0

Security-Policy

Determines if the project has published a security policy.

0

SAST

Determines if the project uses static code analysis.

0

Pinned-Dependencies

Determines if the project has declared and pinned the dependencies of its build process.

0

Fuzzing

Determines if the project uses fuzzing.

0

Vulnerabilities

Determines if the project has open, known unfixed vulnerabilities.

Reason

61 existing vulnerabilities detected

Details

Warn: Project is vulnerable to: GHSA-968p-4wvh-cqc8
Warn: Project is vulnerable to: GHSA-67hx-6x53-jw92
Warn: Project is vulnerable to: GHSA-93q8-gq69-wqmw
Warn: Project is vulnerable to: GHSA-qwcr-r2fm-qrc7
Warn: Project is vulnerable to: GHSA-v6h2-p8h4-qcjw
Warn: Project is vulnerable to: GHSA-grv7-fg5c-xmjg
Warn: Project is vulnerable to: GHSA-w8qv-6jwh-64r5
Warn: Project is vulnerable to: GHSA-pxg6-pf52-xh8x
Warn: Project is vulnerable to: GHSA-3xgq-45jj-v275
Warn: Project is vulnerable to: GHSA-gxpj-cx7g-858c
Warn: Project is vulnerable to: GHSA-rv95-896h-c2vc
Warn: Project is vulnerable to: GHSA-qw6h-vgh9-j6wx
Warn: Project is vulnerable to: GHSA-8r6j-v8pm-fqw3
Warn: Project is vulnerable to: MAL-2023-462
Warn: Project is vulnerable to: GHSA-ww39-953v-wcq6
Warn: Project is vulnerable to: GHSA-pfrx-2q88-qq97
Warn: Project is vulnerable to: GHSA-7wwv-vh3v-89cq
Warn: Project is vulnerable to: GHSA-rc47-6667-2j5j
Warn: Project is vulnerable to: GHSA-7r28-3m3f-r2pr
Warn: Project is vulnerable to: GHSA-r8j5-h5cx-65gg
Warn: Project is vulnerable to: GHSA-896r-f27r-55mw
Warn: Project is vulnerable to: GHSA-9c47-m6qq-7p4h
Warn: Project is vulnerable to: GHSA-6c8f-qphg-qjgp
Warn: Project is vulnerable to: GHSA-76p3-8jx3-jpfq
Warn: Project is vulnerable to: GHSA-3rfm-jhwj-7488
Warn: Project is vulnerable to: GHSA-hhq3-ff78-jv3g
Warn: Project is vulnerable to: GHSA-p6mc-m468-83gw
Warn: Project is vulnerable to: GHSA-35jh-r3h4-6jhm
Warn: Project is vulnerable to: GHSA-952p-6rrq-rcjv
Warn: Project is vulnerable to: GHSA-f8q6-p94x-37v3
Warn: Project is vulnerable to: GHSA-rp65-9cf3-cjxr
Warn: Project is vulnerable to: GHSA-9wv6-86v2-598j
Warn: Project is vulnerable to: GHSA-rhx6-c78j-4q9w
Warn: Project is vulnerable to: GHSA-7fh5-64p2-3v2j
Warn: Project is vulnerable to: GHSA-x7hr-w5r2-h6wg
Warn: Project is vulnerable to: GHSA-hrpp-h998-j3pp
Warn: Project is vulnerable to: GHSA-5q6m-3h65-w53x
Warn: Project is vulnerable to: GHSA-36m4-6v6m-4vpr
Warn: Project is vulnerable to: GHSA-q22g-8fr4-qpj4
Warn: Project is vulnerable to: GHSA-p8p7-x288-28g6
Warn: Project is vulnerable to: GHSA-c2qf-rxjj-qqgw
Warn: Project is vulnerable to: GHSA-44c6-4v22-4mhx
Warn: Project is vulnerable to: GHSA-4x5v-gmq8-25ch
Warn: Project is vulnerable to: GHSA-m6fv-jmcg-4jfg
Warn: Project is vulnerable to: GHSA-cm22-4g7w-348p
Warn: Project is vulnerable to: GHSA-4g88-fppr-53pp
Warn: Project is vulnerable to: GHSA-4jqc-8m5r-9rpr
Warn: Project is vulnerable to: GHSA-g4rg-993r-mgx7
Warn: Project is vulnerable to: GHSA-f5x3-32g6-xq36
Warn: Project is vulnerable to: GHSA-72xf-g2v4-qvf3
Warn: Project is vulnerable to: GHSA-7p7h-4mm5-852v
Warn: Project is vulnerable to: GHSA-cf4h-3jhx-xvhq
Warn: Project is vulnerable to: GHSA-v2p6-4mp7-3r9v
Warn: Project is vulnerable to: GHSA-w573-4hg7-7wgq
Warn: Project is vulnerable to: GHSA-78xj-cgh5-2h22
Warn: Project is vulnerable to: GHSA-2p57-rm9w-gvfp
Warn: Project is vulnerable to: GHSA-vh95-rmgr-6w4m
Warn: Project is vulnerable to: GHSA-xvch-5gv4-984h
Warn: Project is vulnerable to: GHSA-5fw9-fq32-wv5p
Warn: Project is vulnerable to: GHSA-j8xg-fqg3-53r7
Warn: Project is vulnerable to: GHSA-3h5v-q93c-6h6q

Score

3.4

/10

Last Scanned on 2025-06-30

The Open Source Security Foundation is a cross-industry collaboration to improve the security of open source software (OSS). The Scorecard provides security health metrics for open source projects.

Learn More

Other packages similar to kafkajs

Other packages similar to kafkajs

kafkajs

Installations

Developer Guide

Yes

CommonJS

>=14.0.0

14.21.3

6.14.18

Pull Requests

43

750

123

584

Issues

343

1,006

663

Releases

Languages

Developer

Download Statistics

GitHub Statistics

Maintainers

Package Meta Information

Total Downloads

NaN

Weekly Downloads

Monthly Downloads

Yearly Downloads

Dev Dependencies

KafkaJS

Table of Contents

About the Project

Sponsors ❤️

Upstash: Serverless Kafka

Get help directly from a KafkaJS developer

Features

Getting Started

Usage

Contributing

Help wanted 🤝

Contact 💬

License

Acknowledgements

10

10

10

6

0

0

0

0

0

0

0

0

3.4

/10