Search results
99 packages found
Queue producer and consumer tools, with kafka support.
Enqueues messages onto a given SQS queue
AMQP-based Consumer/Producer tool
Distributed Message Pub/Sub Service with socket.io
Consumer and producer abstraction for streaming from a Mongo/Redis event store
Wrapper for KafkaJS library to be used with Strapi apps.
Client for Apache Kafka v0.9.x, v0.10.x and v0.11.x
Language agnostic job queue for SQS
Client for Apache Kafka v0.9.x, v0.10.x and v0.11.x
This package allows you to create an amqplib consumer and producer.
Cooperative Multitasking Lock and Jobs Processing
[![Node.js CI](https://github.com/saularis/rabbitmqueue/actions/workflows/node.js.yml/badge.svg)](https://github.com/saularis/rabbitmqueue/actions/workflows/node.js.yml)
Readable and writable streams for AWS Kinesis
Efficient Node Kinesis Producer Based on Kevin Deng's AWS Big Data Blog
Headless SQS package creates queues if do not exist with a sample configuration.
Prozess is a kafka library for Node.js
Kafka CLI tool
Enqueues messages onto a given SQS queue
A producer Node stream for draining different data, including Readable streams
simple godot producer and readable stream that emits an event with the disk % on each interval