Kafka test clients in Java, Go, Rust, and Python for testing Kafka connectivity.

💎 Diom - components platform for robust services

Orchestrates config based ML data pipeline for ML predictions & events

Periodic task system worker

A Strimzi-compatible Apache Kafka 4.x image maintained by Pletor Co., Ltd.

Manages configuration for EnSync engine. See https://tryensync.com/docs/installations

mosquitto + delay message plugin

Standalone NuVotifier server implementation.

Dockerized Exim on Ubuntu

Pull data from a URL in various formats and pushes the data to an MQTT broker

Handles incoming events from OSDU/Azure Data Manager for Energy and relays them to Azure Event Grid.

Oracle Database CDC and Data Streaming using Kafka Connect

The kafka processor for the Curryware Fantasy application

Whatsapp Api using go

Home Assistant DSMR Reader Add-on

Python's asyncio-native MQTT broker and client.

e-commerce/Retail use case to showcase the capabilities of flink

DeltaForge is a Change Data Capture (CDC) framework to stream db changes into downstream systems.

Collection of images for the backend, frontend and control modules of the p0973 project.

Docker image of RabbitMQ for cloud.iO

A fork of mqttwarn providing timeout support

A containerised Postfix SMTP relay that delivers mail to Office 365 through the Microsoft Graph API.

A web-based Kafka message producer with UI for sending single, interval, and batch messages

e-commerce/Retail use case to showcase the capabilities of flink

Periodic task system client http bridge

Kafka MongoDB sink connector

Prometheus exporter for BullMQ and Redis queue metrics in a lightweight Docker image.

Mosquitto⁠ MQTT broker, libSQL⁠ database and admin web UI in a single image

A simple event stream server.

Simple pubsub system based on FastAPI and PostgreSQL