kafka

🚗 个人技术分享…（主题：高性能架构、中间件原理实践、云原生、Golang 等）

FastStream 是一个非同步 Python 框架，用于构建事件驱动应用，整合消息代理、依赖注入、验证、测试工具与 AsyncAPI 文档生成于一体

AsyncAPI 规范让您能够为异步 API 创建机器可读的定义。

🔥基于 go-zero 微服务全技术栈开发最佳实践项目。Develop best practice projects based on the full technology stack of go zero (go zero) microservices.

用 Rust 开发的分布式流处理引擎。

用 Golang 实作的 Kafka，内建协调功能（无 ZK 依赖，单一二进制安装，云原生）

基于使用量的开发者计费与账单系统 🔓 支持云端或自行部署 ⚙️ 无代码 UI 💰 实时使用量计量 🎟 积分与充值 🔑 功能访问控制

协调端到端加密、加密身份、相互认证与授权政策，适用于大规模分布式应用

高效能开源内存图形数据库，支持 GraphRAG、AI 记忆、代理 AI 与实时图形分析。Cypher 兼容，使用 C++ 开发

使用 Dapr Agentic Cloud Ascent (DACA) 设计模式与 Agent-Native Cloud 技术学习 Agentic AI：OpenAI Agents SDK、Memory、MCP、A2A、Knowledge Graphs、Dapr、Rancher Desktop 与 Kubernetes

Redpanda Console 是一个面向开发者的 UI，协助管理 Kafka/Redpanda 工作负载。Console 提供简单交互式界面，让你能查看主题、遮蔽资料、管理消费者群组，并以时间旅行调试方式探索实时资料

一个现代化的 Apache Kafka 客户端，适用于 node.js

Apache Kafka 的 Kafka GUI，用于管理主题、主题资料、消费者组、模式注册表、连接器等

纽约时报的微服务工具包

docker compose 文件，用于建立完整可运行的 Kafka 堆栈

Alink 是基于 Flink 的机器学习算法平台，由阿里巴巴计算平台 PAI 团队开发。

开源且企业级的 Webhooks 服务 🦀

Surging 是一个微服务引擎，提供轻量级、高性能、模块化的 RPC 请求管道。支持基于事件的异步模式和反应式编程。

快速、简单且具成本效益的工具，用于将数据从 Postgres 复制到数据仓库、队列和存储空间

大数据学习，从零开始学习大数据，包含大数据学习各阶段学习视频、面试资料

一款 AI 驱动、分布式且高性能的监控系统，用于 Kafka 集群的全面监控与管理。

franz-go 是一个功能完整、纯 Go 语言编写的 Kafka 库，支持 0.8.0 到 4.2+ 版本。包含生产、消费、事务、管理等功能。

Cruise-control 是首个完全自动化 Kafka 集群动态工作负载重新平衡与自我修复的工具。它通过简化 Kafka 集群的运行，为 Kafka 用户带来极大价值。

「Java面试小抄」一份通向理想互联网公司的面试汇总，包括 Java基础、Java并发、JVM、MySQL、Redis、Spring、MyBatis、Kafka、计算机操作系统、计算机网络、系统设计、分布式、Java 项目实战等

用于管理 Apache Kafka 集群的开源 Web UI

Goka 是一个为 Apache Kafka 编写、精巧而强大的 Go 语言分布式流处理库。

适用于 Prometheus 的 Kafka 导出工具

使用 .NET 与 C# 构建消息应用程序的框架。

深圳地铁大数据客流分析系统🚇🚄🌟

适用于 Kafka 的 Confluent Schema Registry