Kafka

OLake Go is a high-performance, open-source data ingestion engine that replicates data from databases (PostgreSQL, MySQL, MongoDB, Oracle, DB2,...

Data Engineering Zoomcamp is a free, structured 9-week educational course teaching data engineering fundamentals through hands-on pipeline building...

Bento is a high-performance stream processor that connects various data sources and sinks (Kafka, cloud services, databases, etc.) with declarative...

OpenMeter is an open-source real-time metering and billing platform designed specifically for AI, API, and DevOps monetization. It enables companies...

Svix is an enterprise-ready webhook service and dispatcher written in Rust that handles delivery, retries, security, and reliability for webhook...

Strimzi provides a Kubernetes operator for deploying and managing Apache Kafka clusters on Kubernetes and OpenShift, abstracting away the complexity...

ArkFlow is a high-performance Rust stream processing engine with integrated AI/ML capabilities, designed for real-time data processing, inference,...

rust-rdkafka is a fully asynchronous, futures-based Apache Kafka client library for Rust that wraps librdkafka. It serves Rust developers building...

Debezium is an open-source change data capture (CDC) platform that monitors databases and streams row-level changes as events to Apache Kafka. It...

This is an official Confluent repository hosting curated demos and examples for Apache Kafka, Apache Flink, and Confluent Platform, showcasing event...

Kafbat UI is an open-source web dashboard for monitoring and managing Apache Kafka clusters, enabling operators to inspect brokers, topics, consumer...

Memgraph is a high-performance, in-memory graph database built in C++ that specializes in powering GraphRAG pipelines, AI memory systems, and agentic...

FastStream is an asynchronous Python framework for building event-driven microservices with unified APIs across multiple message brokers (Kafka,...

Akvorado is a specialized network flow collector, enricher, and visualization platform that ingests NetFlow/IPFIX and sFlow data, augments it with...

RobustMQ is a unified messaging engine written in Rust that consolidates multiple messaging protocols (MQTT, Kafka, AMQP, NATS) into a single binary...

Flexprice is a usage-based and credit-based billing infrastructure platform designed for SaaS and AI-native companies. It provides real-time...

Franz-go is a pure Go Apache Kafka client library supporting versions 0.8.0 through 4.2+, offering comprehensive features including transactions,...

CAP is a .NET library that implements distributed transactions and event bus functionality for microservices, using the Outbox Pattern with local...

AutoMQ is a diskless Kafka implementation that runs on S3, designed for cloud-native architectures seeking significant cost reduction and elastic...

Apache Kafka is a distributed event streaming platform designed for high-performance data pipelines, streaming analytics, and mission-critical...

Rsyslog is a high-performance, modular log ingestion and ETL engine written in C, capable of processing over one million messages per second with...

Redpanda is a Kafka-compatible streaming data platform built in C++ without ZooKeeper or JVM dependencies, targeting developers who need lower...

Zerocode is a no-code automated testing framework for REST APIs, SOAP services, Kafka data streams, and databases using JSON/YAML configuration. It...

RisingWave is a SQL-based event streaming platform designed specifically for agentic AI and real-time applications that require continuously fresh,...

AKHQ is a web-based GUI for Apache Kafka that enables management of topics, consumer groups, schema registry, and Kafka Connect. It serves DevOps...

Telegraf is a widely-adopted open-source agent for collecting, processing, and writing metrics, logs, and telemetry data across 300+ plugins. It...

AsyncAPI is a specification for defining machine-readable asynchronous API contracts, similar to OpenAPI for REST APIs. It enables standardized...

Apache Camel is a mature, enterprise-grade integration framework with 350+ connectors for databases, APIs, message brokers, and cloud services. It...

PeerDB is a specialized ETL tool that replicates data from PostgreSQL to data warehouses, message queues, and storage systems using CDC (Change Data...

Watermill is a Go library for building event-driven applications with support for multiple pub/sub transports (Kafka, RabbitMQ, NATS, HTTP,...