KafkaJS | npm.io

Lightweight, tested, straight-forward wrapper around KafkaJS and Confluent's Schema Registry.

kafka kafkajs typescript nestjs kafka events nest nest events nestjs events confluent schema registry

1.1.5 • Published 3 years ago

KafkaJS integration with NestJS, fork by @rob3000/nestjs-kafka:0.1.0

nestjs kafkajs

1.0.0 • Published 4 years ago

KafkaJS connector

kafka kafkajs connector

1.76.3 • Published 1 year ago

NestJS module supporting multiple connections implemented using KafkaJS

nestjs nest kafka kafkajs kafka-js kafka.js kafka-node kafka-nodejs node nodejs

1.1.2 • Published 1 year ago

A prometheus exporter for kafkajs

kafkajs kafka prometheus monitoring metrics kafkajs prometheus kafkajs monitoring kafkajs metrics kafka prometheus kafka monitoring

3.2.0 • Published 1 year ago

NestJS Kafka

nestjs nestjs/kafka nestjs/kafka-module nestjs-kafka kafkajs kafka

0.1.9 • Published 1 year ago

simple integrate kafka.js with nest.js

nestjs kafkajs

0.0.3 • Published 3 years ago

This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.

kafka kafkajs node-red

0.0.6 • Published 3 years ago

Custom partition assigner to handle multiple consumers under same group

kafka kafkajs partition-assigner

1.0.1 • Published 2 years ago

Control batch size for kafkajs consumers

kafkajs max.poll.records batcher

1.0.2 • Published 2 years ago

OpenTelemetry kafkajs automatic instrumentation package.

instrumentation kafkajs nodejs opentelemetry profiling kafka tracing

0.45.0 • Published 2 years ago

Wrapper for KafkaJS library to be used with Strapi apps.

strapi plugin kafka kafkajs publisher subscriber pub sub producer consumer

1.2.11 • Published 3 years ago

LZ4 compression codec for JS.

kafka kafkajs compression lz4 codec

0.0.1 • Published 3 years ago

Authentication mechanism for AWS MSK IAM for KafkaJS.

kafkajs msk iam authentication aws

3.1.2 • Published 2 years ago

KafkaJS + unopinionated Avro encoding/decoding based on subject and version

avro kafkajs kafka decode encode

1.0.1 • Published 6 years ago

Lightweight, tested, straight-forward wrapper around KafkaJS and Confluent's Schema Registry.

kafka kafkajs typescript nestjs kafka events nest nest events nestjs events confluent schema registry

1.0.9 • Published 4 years ago

Kafka integration with NestJS

nestjs kafkajs kafka

0.0.1 • Published 4 years ago

OpenTelemetry instrumentation for `kafkajs` messaging client for Apache Kafka

kafkajs instrumentation nodejs opentelemetry profiling tracing

0.4.0 • Published 9 months ago

A no fuss rxjs wrapper for kafkajs, focused on ease of use.

kafka kafkajs rxjs reactivex

1.1.0 • Published 3 years ago

rxjs + kafkajs

rxjs-kafkajs kafka kafkajs rx rxjs observable

1.0.0 • Published 4 years ago

KafkaJS Packages

@alexknips/nestjs-kafka-events

@allesa/nestjs-kafka

@biorate/kafkajs

@buka/nestjs-kafka

@christiangalsterer/kafkajs-prometheus-exporter

@choewy/nestjs-kafka

@claudeseo/nest-kafka

@clevabit/node-red-contrib-kafkajs

@gswag/kafkajs-partition-assigner

@gtdudu/kafkajs-batcher

@heliosphere/opentelemetry-instrumentation-kafkajs

@indoomni/strapi-plugin-kafkajs

@kafkaman-labs/kafkajs-lz4

@jm18457/kafkajs-msk-iam-authentication-mechanism

@ivosequeros/kafkajs-avro

@jucr/nestjs-kafka-events

@petrovdv/nestjs-kafka-client

@opentelemetry/instrumentation-kafkajs

rxjs-kafka

rxjs-kafkajs