Mirror of Apache Kafka
The event streaming database purpose-built for stream processing applications
Demo applications and code examples for Apache Kafka's Streams API.
Provides Familiar Spring Abstractions for Apache Kafka
Xinfra Monitor monitors the availability of Kafka clusters by producing synthetic workloads using end-to-end pipelines to obtain derived vital statistics - E2E latency, service availability & message loss rate. It reassigns partition & trigger preferred leader election to ensure each broker acts as leader of at least 1 partition of monitor topic.
Kafka Connect connector for JDBC-compatible databases
A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues