Kafka
Showing 36 of 109 projects
A Python ETL framework for stream processing, real-time analytics, and building live LLM/RAG pipelines, powered by a scalable Rust engine.
A distributed event streaming platform for building high-performance data pipelines, streaming analytics, and data integration.
A plugin-driven agent for collecting, processing, aggregating, and writing metrics, logs, and arbitrary data.
A plugin-driven agent for collecting, processing, aggregating, and writing metrics, logs, and arbitrary data.
A C++ parallel computing and asynchronous networking framework for building high-performance, high-concurrency backend services.
A low-latency platform for change data capture (CDC) that streams row-level changes from databases to applications.
A Kafka-compatible streaming data platform that is 10x faster, simpler to operate, and free from ZooKeeper and JVMs.
A Kafka-compatible streaming data platform that's 10x faster, with no ZooKeeper or JVM.
A Kafka-compatible streaming data platform that's 10x faster, with no ZooKeeper or JVM dependencies.
A Go client library for Apache Kafka with comprehensive API support and testing utilities.
A web-based tool for managing Apache Kafka clusters, enabling cluster inspection, topic management, and partition operations.
AutoMQ is a cloud-native, diskless Kafka alternative that uses S3 for storage, offering 10x cost savings, autoscaling in seconds, and single-digit ms latency.
A diskless Kafka alternative that runs on S3, offering 10x cost savings, autoscaling in seconds, and single-digit ms latency.
An enterprise-grade event streaming platform that ingests, processes, and manages real-time event data with PostgreSQL compatibility and Apache Iceberg™ integration.
Enterprise-grade event streaming platform that continuously ingests, processes, and serves real-time data with Apache Iceberg™ integration.
A .NET library for distributed transactions and event bus integration in microservices using the Outbox pattern.
Python Stream Processing
A real-time data integration platform that creates and continually updates consistent views of transactional data using SQL.
An asynchronous thread pool framework for Java applications that supports dynamic configuration changes, monitoring, and alerting without code modifications.
An asynchronous Python framework for building services that interact with Apache Kafka, RabbitMQ, NATS, and Redis event streams.
A specification for creating machine-readable definitions of asynchronous APIs, similar to OpenAPI for REST.
A distributed stream processing engine in Rust that performs stateful computations on real-time data with subsecond results.
An MLOps framework to package, deploy, monitor, and manage thousands of production machine learning models on Kubernetes.
Orchestrate end-to-end encryption, cryptographic identities, mutual authentication, and authorization policies between distributed applications at scale.
Orchestrate end-to-end encryption, cryptographic identities, mutual authentication, and authorization policies between distributed applications at scale.
A MySQL change data capture daemon that streams database changes as JSON to Kafka, Kinesis, and other platforms.
A .NET command dispatcher and processor framework for building loosely coupled applications and microservices with in-process and out-of-process messaging.
A RESTful service for storing, retrieving, and managing Avro, JSON Schema, and Protobuf schemas in Apache Kafka ecosystems.
A full-stack .NET 10 reference application demonstrating Clean Architecture with support for monoliths, modular monoliths, and microservices.
A single C++ binary SQL engine for high-performance stream processing, analytics, observability, and AI/ML pipelines.
A Ruby and Rails multi-threaded framework for building efficient Kafka-based event-driven applications.
Production-ready messaging solution for PHP with support for message queues, job queues, broadcasting, and WebSockets across multiple frameworks.
A lightweight and efficient stream processing library for Go, providing a declarative DSL to build data pipelines.
A Python framework and Rust-based distributed processing engine for stateful event and stream processing.
A fully asynchronous, futures-based Apache Kafka client library for Rust built on librdkafka.
A Python stream processing library that ports Kafka Streams concepts to Python, enabling scalable event processing and in-memory durable key/value stores.
Related Tags
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.