Search results
99 packages found
Queue producer and consumer tools, with kafka support.
AMQP-based Consumer/Producer tool
Enqueues messages onto a given SQS queue
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
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)
This package allows you to create an amqplib consumer and producer.
Readable and writable streams for AWS Kinesis
Prozess is a kafka library for Node.js
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.
Kafka CLI tool
Enqueues messages onto a given SQS queue
A log api that provides log producers with an interface with a rabbitMQ log queue
A producer Node stream for draining different data, including Readable streams