Mirror of Apache Kafka

AutoMQ is a cloud-native fork of Kafka by separating storage to S3. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.

Oxia Official Helm charts for deploying the Oxia on Kubernetes.

Apache Pulsar - distributed pub-sub messaging system

Oxia - Metadata store and coordination system

OpenTalaria is a lightweight message broker that implements the Kafka protocol and persists messages in PostgreSQL and other databases.

Service agnostic KV store benchmark framework

Oxia Java client SDK

Fluss is a streaming storage built for real-time analytics.

Memory for AI Agents; Announcing OpenMemory MCP - local and secure memory management.

OpenTelemetry auto-instrumentation and instrumentation libraries for Java

Apache Doris is an easy-to-use, high performance and unified analytics database.

Apache BookKeeper - a scalable, fault tolerant and low latency storage service optimized for append-only workloads

Prometheus instrumentation library for JVM applications

MQTT on Pulsar implemented using Pulsar Protocol Handler

TiKV Java Client

Kafka exporter for Prometheus

chao test

Contrib repository for the OpenTelemetry Collector

🐠 Beats - Lightweight shippers for Elasticsearch & Logstash

The Java agent for Apache SkyWalking

Apache Pulsar Site

Netty project - an event-driven asynchronous network application framework

OpenMessaging Benchmark Framework

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

A better compressed bitset in Java: used by Apache Spark, Netflix Atlas, Apache Pinot, Tablesaw, and many others

Elastic APM Java Agent

Apache Pulsar Go Client Library

Apache Lucene open-source search software