Kafka
Showing 36 of 109 projects
A fault-tolerant service that persists Kafka log data to cloud storage like S3, GCS, Azure Blob Storage, and OpenStack Swift.
A unified messaging engine built in Rust that supports MQTT, Kafka, NATS, AMQP, and mq9 protocols on a single shared storage layer.
A lambda architecture framework on Apache Spark and Kafka for building and deploying real-time large-scale machine learning applications.
A stateless, multi-protocol proxy that bridges web apps, IoT devices, and microservices directly to Apache Kafka via declarative APIs.
A Python framework for building real-time data pipelines and event-driven microservices on Apache Kafka using a Streaming DataFrame API.
Integration testing toolkit that spins up ephemeral Docker containers for dependencies, eliminating the need for mocks.
A distributed, Prometheus-compatible, real-time, in-memory time series database designed for massive scalability and low-latency operational metrics.
A pure Rust client library for Apache Kafka with consumer, producer, and client APIs.
A Reactive Streams connector for Apache Kafka built on Akka Streams, enabling back-pressured integration for Java and Scala.
asyncio client for kafka
An extensible open-source framework for running, monitoring, and managing honeypots to detect and analyze cyber threats.
A high-performance Rust stream processing engine with integrated AI capabilities for real-time data processing and intelligent analysis.
A lightweight suite of passive network monitoring tools supporting NetFlow, sFlow, IPFIX, libpcap, and BGP telemetry.
A high-performance, scalable, and reliable enterprise network flow collector for IPFIX, sFlow, and Netflow protocols.
An open-source, in-memory, distributed batch and stream processing engine for Java applications.
A high-performance C/C++ client library for Apache Kafka, supporting producers, consumers, and admin operations.
A high-performance Rust application framework inspired by Spring Boot, emphasizing convention over configuration.
A no-code automated testing framework for microservices APIs, Kafka data streams, databases, and load testing using JSON/YAML.
An extensible distributed system for reliable nearline data streaming at scale
A distributed event bus broker providing a RESTful API abstraction over Kafka-like queues for real-time data streaming.
A fast, secure, and standalone log collector written in Rust that parses, validates, and forwards log data.
LinkedIn's previous generation Kafka to HDFS pipeline for batch data ingestion.
A distributed MQTT broker built on Kafka, handling 100M+ connections and 10M+ messages/sec with industrial-grade persistence.
A self-service IoT toolbox enabling non-technical users to connect, analyze, and explore industrial IoT data streams.
A low-code visual tool for domain experts to build, run, and monitor real-time decision algorithms on streaming data.
A lightweight, extensible messaging framework for .NET supporting pub/sub and request-response patterns with multiple broker integrations.
A gateway that enables reactive, event-driven communication between frontend clients and stateless microservices.
A .NET stream processing library for Apache Kafka, providing a Kafka Streams-like API for building real-time applications.
A .NET stream processing library for Apache Kafka, providing a Kafka Streams-like API for building real-time applications.
Simplified command-line administration tool for Kafka brokers, providing essential management operations.
A Python library for constructing reactive dataflow graphs and streaming computations as data models.
A unified data replication platform for TiDB, providing MySQL/MariaDB migration and change data capture to downstream systems.
A Java SDK for creating, manipulating, and transporting CloudEvents across various protocols and formats.
A web UI for managing Avro schemas in Confluent Schema Registry, enabling creation, viewing, searching, evolution, and configuration.
A Clojure framework for building stateless stream processing applications on Kafka with built-in retry mechanisms.
A proxy service that offloads event processing, normalization, and ingestion from Sentry SDKs and server.
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.