npmpackage.info

Gathering detailed insights and metrics for kafkajs

Other packages similar to kafkajs

@opentelemetry/instrumentation-kafkajs

0.5.0

OpenTelemetry instrumentation for `kafkajs` messaging client for Apache Kafka

kafkajs-snappy

1.1.0

Snappy codec for KafkaJS

opentelemetry-instrumentation-kafkajs

0.41.0

open telemetry instrumentation for the `kafkajs` kafka client

kafkajs-lz4

2.0.0-beta.0

LZ4 compression codec for the KafkaJS library

Gathering detailed insights and metrics for kafkajs

kafkajs

A modern Apache Kafka client for node.js

2.2.4

3,761

MIT

JavaScript

59.64 kB

118,884,509 3.4

Installations

npm install kafkajs

Pull Requests

Open

38

Total

739

Closed

117

Merged

584

Issues

Open

327

Total

987

Closed

660

Releases

v2.2.4

Published on 27 Feb 2023

v2.2.3

Published on 21 Nov 2022

v2.2.2

Published on 18 Oct 2022

v2.2.1

Published on 13 Oct 2022

v2.2.0

Published on 16 Aug 2022

v2.1.0

Published on 28 Jun 2022

View all 46 releases

Developer

tulios

Developer Guide

BETA

Module System

CommonJS

Min. Node Version

>=14.0.0

Typescript Support

Yes

Node Version

14.21.3

NPM Version

6.14.18 Statistics

3,761 Stars

3,097 Commits

529 Forks

37 Watching

27 Branches

116 Contributors

Updated on 27 Nov 2024

Bundle Size

259.47 kB

Minified

59.64 kB

Minified + Gzipped

Bundlephobia

Languages

JavaScript (98.33%)

Shell (0.87%)

TypeScript (0.55%)

Java (0.14%)

CSS (0.11%)

Total Downloads

Cumulative downloads

Total Downloads

118,884,509

Last day

-0.9%

230,159

Compared to previous day

Last week

2.1%

1,231,765

Compared to previous week

Last month

16.2%

4,946,848

Compared to previous month

Last year

26.3%

47,389,121

Compared to previous year

Daily Downloads

Weekly Downloads

Monthly Downloads

Yearly Downloads

Versions

KafkaJS

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

Read the Docs · Report Bug · Request Feature

About the project
- Features
- Getting Started
  - Usage
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.

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

Binary-Artifacts

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

10

License

Determines if the project has defined a license.

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

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

SAST

Determines if the project uses static code analysis.

0

Vulnerabilities

Determines if the project has open, known unfixed vulnerabilities.

Reason

56 existing vulnerabilities detected

Details

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-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-7fh5-64p2-3v2j
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 / 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 2024-11-18

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

Pull Requests

38

739

117

584

Issues

327

987

660

Releases

Developer

Developer Guide

CommonJS

>=14.0.0

Yes

14.21.3

6.14.18

Statistics

Bundle Size

259.47 kB

59.64 kB

Languages

Total Downloads

118,884,509

Daily Downloads

Weekly Downloads

Monthly Downloads

Yearly Downloads

Dev Dependencies

KafkaJS

Table of Contents

About the Project

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