#kafka

Your API mocking tool for OpenAPI and AsyncAPI using Go and JavaScript - https://mokapi.io

An interactive terminal user interface (TUI) application for exploring data of a kafka cluster.

A Grafana datasource plugin for Apache Kafka

Service runtime for Python control planes. Config, logging, metrics, health, secrets and deployment contracts, wired together.

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

High-performance multi-data-source database client — ~30MB, AI & MCP ready, zero Electron bloat. | 高性能多数据源数据库客户端：约 30MB，AI 与 MCP 就绪，告别 Electron 膨胀。

The Go implementation of the Couchbase to Kafka with DCP.

Flow collector, enricher and visualizer

Kafka Connect connector for JDBC-compatible databases

Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern

Use Kafka Producers and Consumers in your laravel app with ease!

Silverback is a message bus and broker integration library for .NET. It is designed to simplify event-driven architectures and asynchronous messaging, with first-class support for Apache Kafka and MQTT.

Moro is a high-performance, type-safe API framework with intelligent routing and multi-runtime support (Node, Edge, Lambda, Workers).

Build with AI. Run with guarantees. TPF is a Java framework for strongly typed business flows that compose model decisions, authorised SaaS capabilities, and deterministic code—with durable effects, waits, retries, replay, observability, and flexible deployment.

The Data Control Plane for AI Agents — acquire, validate, and land data over MCP with scoped keys, approval gates, and an audit log. Self-hosted, open source.

Event sourcing journal implementation using Kafka as main storage

A crate to convert bytes to something more useable and the other way around in a way Compatible with the Confluent Schema Registry. Supporting Avro, Protobuf, Json schema, and both async and blocking.

Rust client for Apache Kafka

Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.

Async Rust library to route messages between Kafka, NATS, MQTT, AMQP, databases and HTTP, with Python and Node bindings

Official Node.js client for the General Coordinates Network (GCN)