A "generic" Argo EventSource implementation supporting NATS Jetstream

RabbitMQ with message deduplication plugin for reliable, duplicate-free messaging.

Data orchestration and workflow automation for building, running, and monitoring data flows.

Monitor the working daemons from table or MS

The enterprise-grade Apache Kafka developer, management and governance platform trusted worldwide.

High-performance WhatsApp Gateway API with Queue support (Redis + BullMQ) built on Baileys.

Docker image for the OpenLDES server.

需配合 - Minio - RabbitMQ 搭配使用

run aprsc in Scratch image

MQTT Client Generator - Generates clients sending fake data (numbers 50-300) to EMQX every second.

Async rabbitmq reports consumer server for cdc-microservices

micro servicio de colas

A web-assembly extensible, composable, kafka processor that supports hot-reloading

opclabs/uademopublisher

opclabs

A demonstration publisher for OPC UA PubSub.

Public endpoint to collect, cache and share position data.

lensesio/mcp

lensesio

Lenses local MCP server, LLM to Kafka

mosquitto + delay message plugin

Service Department Telegram Bot

pg2sqs streams PostgreSQL WAL (Write-Ahead Log) records to an AWS SQS queue

A real-time bridge between Ko-fi webhooks and WebSocket connections.

A flexible Kafka container image with dynamic configuration and production-ready startup logic.

AISStream.io mqtt connector for home assistant

A tiny, ultra-lightweight message broker for side projects, prototypes, and internal tools.

Beti fortalece - Telegram Chatbot com API Key do Gemini e Python para o atendimento de clientes.

A Bambulab focused filament management system.

xomoxcc/mqttstuff

xomoxcc

Python utilities for MQTT: publish/subscribe wrappers, retained message readers, Tasmota discovery

LogPilot-Lite is a lightweight, standalone log collection system.