446 packages found
Client for Apache Kafka v0.9.x, v0.10.x and v0.11.x
Kafka consumer manager handles retries, offset issues and retries
Node.js bindings for librdkafka
kafka avro serialization
Used to filter topic messages in the past to build a state object to use when validating incoming messages.
Fastify plugin to interact with Apache Kafka.
rxjs + kafkajs
This JS-script calculates the partition based on a key and the amount of partitions for a JS Kafka producer in way consistent to the default Java Kafka client
Helper for exposing node-rdkafka statistics through prometheus
Node.js bindings for librdkafka
Node.js bindings for librdkafka
A fork of kafka-node Client for Apache Kafka v0.8.1+, v0.9.x, and v0.10.x
An express middleware to route requests to kafka
message validator through asyncapi schema
Client for Apache Kafka v0.9.x, v0.10.x and v0.11.x
no-kafk hack to access metadata for healthcheck