#kafka

Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.

Sarama is a Go library for Apache Kafka.

The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL

Powertools for AWS is a developer toolkit to implement Serverless best practices and increase developer velocity.

The open source and enterprise-ready webhooks service 🦀

Python Streaming DataFrames for Kafka

Fancy stream processing made operationally mundane

Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

CLI for Confluent Cloud and Confluent Platform

Community driven, reusable components for distributed apps

OLake - Fastest Databases, Kafka & S3 Replication to Apache Iceberg with Table optimization (Called OLake Fusion). ⚡ Efficient, quick and scalable data ingestion for real-time analytics. Supported sources : Postgres, MongoDB, MySQL, Oracle, MSSql, DB2, Kafka, S3.

A library to build streaming applications that consume from and produce to Kafka.

Ruby and Rails efficient Kafka processing framework

Kroxylicious, the snappy open source proxy for Apache Kafka®

Redpanda Console is a developer-friendly UI for managing your Kafka/Redpanda workloads. Console gives you a simple, interactive approach for gaining visibility into your topics, masking data, managing consumer groups, and exploring real-time data with time-travel debugging.

Conduit streams data between data stores. Kafka Connect replacement. No JVM required.