crates.io
milenkovicm/testcontainers-redpanda-rs
Rust Redpanda Testcontainer
MITAug 16, 2026 · metrics 2.10.0
All tags
Catalogue tag
#kafka
Every repository in the public record carrying this tag — from its GitHub topics or the keywords its package registries publish. Health is measured under the same versioned methodology as the rest of the record.
125 records
Go
tx7do/kratos-transport
kratos transport layer extension, support: rabbitmq,kafka,rocketmq,activemq,apollo,mcp,tcp,websocket...
MITJul 20, 2026 · metrics 2.10.0
Maven
waabox/andersoni
In-memory indexed cache library for Java 21. Fluent DSL, lock-free reads, pluggable sync (Kafka, HTTP, DB), leader election, and snapshot persistence.
Apache-2.0Jul 24, 2026 · metrics 2.10.0
Go
zillow/zkafka
An efficient and scalable library for stateless Kafka message processing written in Go
Apache-2.0Sep 1, 2026 · metrics 2.10.0
PyPI
enesgulerdev/sentinel
Sub-millisecond AI fraud detection at enterprise scale. Engineered for high-throughput predictability.
MITJul 27, 2026 · metrics 2.10.0
Packagist
simPod/PhpKafkaBundle
Kafka bundle for Symfony
MITAug 23, 2026 · metrics 2.10.0
Go
goforj/events
Typed event bus for Go with local dispatch and distributed pub/sub drivers (NATS, Redis, Kafka, SNS, Google Pub/Sub).
MITJul 19, 2026 · metrics 2.10.0
Packagist
simPod/PhpKafka
PHP Kafka boilerplate wrapper around RdKafka
MITJul 31, 2026 · metrics 2.10.0
Maven
javahongxi/whatsmars
Java生态研究(Spring Boot + Redis + Dubbo + RocketMQ + Elasticsearch)🔥🔥🔥🔥🔥 (Spring Boot 3.5.x)
Apache-2.0Jul 18, 2026 · metrics 2.10.0
Hex
Strech/avrora
A convenient Elixir library to work with Avro messages, schemas and Confluent® Schema Registry
MITJul 17, 2026 · metrics 2.10.0
Go
liangboceo/yuanboot
yuanboot
MITJul 17, 2026 · metrics 2.10.0
Go
peymanahmadi/riskguard
Concurrency-safe Go library for real-time payment fraud/risk detection — velocity limits, impossible-travel detection, blacklists, pluggable storage (Postgres/Kafka)
MITAug 5, 2026 · metrics 2.10.0
Go
devilreza/shunt
A Kafka router for Go, built on IBM/sarama (https://github.com/IBM/sarama): register a handler per topic and get consumer-group consumption, composable retry chains (in-process and retry-topic based), dead-letter queues, and bounded worker pools — with at-least-once delivery and per-partition ordering on the happy path.
MITAug 1, 2026 · metrics 2.10.0
Maven · npm
ekbatan-io/ekbatan
Modern Java persistence framework for Event-driven systems. Built-in outbox pattern. Atomic transactions with domain events. Spring, Quarkus, Micronaut, or pure Java
Apache-2.0Sep 1, 2026 · metrics 2.10.0
Go · PyPI
csnyder256/kafka-wire
Kafka wire protocol broker in a single Go binary. Consumer groups, SASL, TLS, ACLs, Prometheus, S3 tiering. Runs anywhere Docker runs.
MITSep 2, 2026 · metrics 2.10.0
Maven
lxil520/nexary
Java middleware framework for cache, messaging, jobs, and governance extensions.
Apache-2.0Aug 26, 2026 · metrics 2.10.0
npm
meetsmore/matador
A batteries-included event system.
No licenseJul 22, 2026 · metrics 2.10.0
Go
thalesfsp/queue
Queue Abstraction Layer provides a highly flexible and extensible queue interface that provides a unified way to interact with different queue backends
MITJul 17, 2026 · metrics 2.10.0
Go
minghsu0107/random-talk
Modern real-time chat in scalable architecture.
MITJul 17, 2026 · metrics 2.10.0
Maven
zhisheng17/flink-learning
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Apache-2.0Aug 5, 2026 · metrics 2.10.0
NuGet
eQuantic/core
Implementations based on design patterns
MITAug 4, 2026 · metrics 2.10.0
Go
hhromic/kadumper
Kafka Avro dumping utility written in Go.
Apache-2.0Jul 18, 2026 · metrics 2.10.0
Go
kudobuilder/kudo
Kubernetes Universal Declarative Operator (KUDO)
Apache-2.0Aug 9, 2026 · metrics 2.10.0
Go
ozontech/file.d
A blazing fast tool for building data pipelines: read, process and output events. Our community: https://t.me/file_d_community
BSD-3-ClauseJul 23, 2026 · metrics 2.10.0
Maven · npm
provectus/kafka-ui
Open-Source Web UI for Apache Kafka Management
Apache-2.0Aug 27, 2026 · metrics 2.10.0
Go · PyPI
redpanda-data/redpanda
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Custom licenseAug 27, 2026 · metrics 2.10.0
Maven
ozangunalp/kafka-native
Kafka broker compiled to native using Quarkus and GraalVM.
Apache-2.0Jul 25, 2026 · metrics 2.10.0
Go
Votline/EnBooster
Gamified, event-driven Telegram bot for language learning. Built with Go microservices, it leverages gRPC, Kafka, PostgreSQL, and multi-instance Redis. Features algorithmic tasks, the Shiritori word game, smart caching, and a local NLP pipeline (Vosk/RHVoice/Ollama) for offline voice and AI chatting. Designed for high resilience and scale.
MITSep 6, 2026 · metrics 2.10.0
Go
dataflow-operator/dataflow
DataFlow Operator is a Kubernetes operator for streaming data between different data sources with support for message transformations.
No licenseJul 26, 2026 · metrics 2.10.0
NuGet
Azure/azure-functions-kafka-extension
Kafka extension for Azure Functions
MITAug 28, 2026 · metrics 2.10.0