全部标签
目录标签

#kafka

公开记录中带有此标签的全部仓库——标签来自其 GitHub 主题或软件包注册表发布的关键词。健康度量遵循与记录其余部分相同的版本化方法论。

125 条记录
标签为“kafka”按健康指数排序
Go
57中等健康指数
tx7do/kratos-transport
kratos transport layer extension, support: rabbitmq,kafka,rocketmq,activemq,apollo,mcp,tcp,websocket...
Go★ 4442026年7月20日
MIT2026年7月20日 · 指标 2.10.0
Maven
57中等健康指数
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.
Java★ 02026年7月24日
Apache-2.02026年7月24日 · 指标 2.10.0
Go
57中等健康指数
zillow/zkafka
An efficient and scalable library for stateless Kafka message processing written in Go
Go★ 702026年9月1日
Apache-2.02026年9月1日 · 指标 2.10.0
PyPI
56中等健康指数
enesgulerdev/sentinel
Sub-millisecond AI fraud detection at enterprise scale. Engineered for high-throughput predictability.
Python · Go · HCL★ 02026年7月27日
MIT2026年7月27日 · 指标 2.10.0
Packagist
56中等健康指数
simPod/PhpKafkaBundle
Kafka bundle for Symfony
PHP★ 8↓ 3,323/月2026年8月23日
MIT2026年8月23日 · 指标 2.10.0
Go
54中等健康指数
goforj/events
Typed event bus for Go with local dispatch and distributed pub/sub drivers (NATS, Redis, Kafka, SNS, Google Pub/Sub).
Go★ 12026年7月19日
MIT2026年7月19日 · 指标 2.10.0
Packagist
54中等健康指数
simPod/PhpKafka
PHP Kafka boilerplate wrapper around RdKafka
PHP★ 6↓ 3,784/月2026年7月31日
MIT2026年7月31日 · 指标 2.10.0
Maven
53中等健康指数
javahongxi/whatsmars
Java生态研究(Spring Boot + Redis + Dubbo + RocketMQ + Elasticsearch)🔥🔥🔥🔥🔥 (Spring Boot 3.5.x)
Java★ 1,9672026年7月18日
Apache-2.02026年7月18日 · 指标 2.10.0
Hex
51中等健康指数
Strech/avrora
A convenient Elixir library to work with Avro messages, schemas and Confluent® Schema Registry
Elixir★ 113↓ 18K/月2026年7月17日
MIT2026年7月17日 · 指标 2.10.0
Go
51中等健康指数
Go★ 32026年7月17日
MIT2026年7月17日 · 指标 2.10.0
Go
50中等健康指数
peymanahmadi/riskguard
Concurrency-safe Go library for real-time payment fraud/risk detection — velocity limits, impossible-travel detection, blacklists, pluggable storage (Postgres/Kafka)
Go★ 12026年8月5日
MIT2026年8月5日 · 指标 2.10.0
Go
47薄弱健康指数
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.
Go★ 32026年8月1日
MIT2026年8月1日 · 指标 2.10.0
Maven · npm
47薄弱健康指数
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
Java · MDX★ 202026年9月1日
Apache-2.02026年9月1日 · 指标 2.10.0
Go · PyPI
44薄弱健康指数
csnyder256/kafka-wire
Kafka wire protocol broker in a single Go binary. Consumer groups, SASL, TLS, ACLs, Prometheus, S3 tiering. Runs anywhere Docker runs.
Go · Python★ 22026年9月2日
MIT2026年9月2日 · 指标 2.10.0
Maven
44薄弱健康指数
lxil520/nexary
Java middleware framework for cache, messaging, jobs, and governance extensions.
Java · Vue★ 22026年8月26日
Apache-2.02026年8月26日 · 指标 2.10.0
npm
44薄弱健康指数
meetsmore/matador
A batteries-included event system.
TypeScript★ 0↓ 26.1K/月2026年7月22日
无许可证2026年7月22日 · 指标 2.10.0
Go
42薄弱健康指数
thalesfsp/queue
Queue Abstraction Layer provides a highly flexible and extensible queue interface that provides a unified way to interact with different queue backends
Go★ 02026年7月17日
MIT2026年7月17日 · 指标 2.10.0
Go
41薄弱健康指数
minghsu0107/random-talk
Modern real-time chat in scalable architecture.
Go · JavaScript★ 4322026年7月17日
MIT2026年7月17日 · 指标 2.10.0
Maven
39薄弱健康指数
zhisheng17/flink-learning
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Java★ 15.1K2026年8月5日
Apache-2.02026年8月5日 · 指标 2.10.0
NuGet
37薄弱健康指数
eQuantic/core
Implementations based on design patterns
C#★ 22026年8月4日
MIT2026年8月4日 · 指标 2.10.0
Go
35薄弱健康指数
hhromic/kadumper
Kafka Avro dumping utility written in Go.
Go★ 02026年7月18日
Apache-2.02026年7月18日 · 指标 2.10.0
Go
34存在风险健康指数
kudobuilder/kudo
Kubernetes Universal Declarative Operator (KUDO)
Go★ 1,2152026年8月9日
Apache-2.02026年8月9日 · 指标 2.10.0
Go
34存在风险健康指数
ozontech/file.d
A blazing fast tool for building data pipelines: read, process and output events. Our community: https://t.me/file_d_community
Go★ 4962026年7月23日
BSD-3-Clause2026年7月23日 · 指标 2.10.0
Maven · npm
34存在风险健康指数
provectus/kafka-ui
Open-Source Web UI for Apache Kafka Management
Java · TypeScript★ 12.3K2026年8月27日
Apache-2.02026年8月27日 · 指标 2.10.0
Go · PyPI
34存在风险健康指数
redpanda-data/redpanda
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
C++ · Python★ 12.5K2026年8月27日
自定义许可证2026年8月27日 · 指标 2.10.0
Maven
28存在风险健康指数
ozangunalp/kafka-native
Kafka broker compiled to native using Quarkus and GraalVM.
Java★ 1152026年7月25日
Apache-2.02026年7月25日 · 指标 2.10.0
Go
24存在风险健康指数
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.
Go★ 02026年9月6日
MIT2026年9月6日 · 指标 2.10.0
Go
22存在风险健康指数
dataflow-operator/dataflow
DataFlow Operator is a Kubernetes operator for streaming data between different data sources with support for message transformations.
Go★ 32026年7月26日
无许可证2026年7月26日 · 指标 2.10.0