apache/kafka
Apache Kafka - A distributed event streaming platform
A star delta has been computed for 52,825 of 62,640 tracked repositories in this period, and only those can be ranked in it.
A repository missing here has not been measured far enough back yet. That does not mean it did not move.
Star counts measured between 00:37 and 04:32 (BKK).
Apache Kafka - A distributed event streaming platform
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.
Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.
Open-Source Web UI for managing Apache Kafka clusters
Metering and Billing for AI, API and DevOps. Collect and aggregate millions of usage events in real-time and enable usage-based billing.
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
franz-go is a feature complete, pure Go library for Kafka from 0.8.0 through 4.4+. Producing, consuming, transacting, administrating, etc.
High-performance multi-data-source database client — ~30MB, AI & MCP ready, zero Electron bloat. | 高性能多数据源数据库客户端：约 30MB，AI 与 MCP 就绪，告别 Electron 膨胀。
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.
The open source and enterprise-ready webhooks service 🦀
High-performance open-source in-memory graph database for GraphRAG, AI memory, agentic AI, and real-time graph analytics. Cypher-compatible, built in C++.
Flow collector, enricher and visualizer
Communication infrastructure for the AI era — one binary, one broker, one storage layer, any protocol
🔥 🔥 官方推荐 🔥 🔥 高并发大麦网售票系统，使用 SpringCloud、Kafka、Redis、Sentinel、ElasticSearch、ShardingSphere 等，通过优化锁的策略、多级缓存管理、数据提前预热、精确的定制限流等多种策略，显著的降低下单延迟。此外还解决各种高并发难题的实际落地解决方案。是面试、就业、提高技术的不二选择！
Free and open log management
Apache Camel is an open source integration framework with 350+ connectors. Write routes in Java, YAML, or XML. Run on Spring Boot, Quarkus, or standalone. Apache License 2.0.
Diskless Kafka® on S3. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency. Multi-AZ Availability.
Distributed stream processing engine in Rust
Kafka broker embedded in postgres
High performance sFlow/IPFIX/NetFlow Collector
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
Apache Kafka® running on Kubernetes
Cruise-control is the first of its kind to fully automate the dynamic workload rebalance and self-healing of a Kafka cluster. It provides great value to Kafka users by simplifying the operation of Kafka clusters.
The ultimate distributed MQTT broker. Handles 100M+ connections and 10M msg/sec with ease. Built on Kafka to provide industrial-grade persistence and eliminate data loss.
Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
Showing 30 of 101 repositories