好开源，值得被发现。

本项目提供基于AWS的无服务器点击流数据管道，通过API Gateway接收实时点击事件，经Kinesis Data Streams摄取后由Firehose转换为Parquet格式并存储至S3数据湖。AWS Glue编目架构，Athena支持SQL查询，EventBridge调度Lambda自动修复分区。项目使用AWS SAM和CloudFormation实现可重复、版本控制的IaC部署。

AllSource 是一个基于 Rust 的 AI 原生事件存储，具有高吞吐量摄取、低延迟读取和原生 MCP 集成，用于 AI 代理。它支持无 Postgres 的持久事件溯源，包括代理内存引擎，并提供社区和企业版。

go-kafka是一个Go语言Kafka客户端库，基于franz-go封装，提供有界的Kafka生产者、消费者、重放、检查和事务性构建块，不隐藏投递结果、生命周期归属或主题策略。

Lexos是一个事件驱动的AI文档处理引擎，结合Go网关、Python工作器、Redis队列和自托管模型，实现离线RAG、摘要和语音转录。

Watermill 是一个用于构建事件驱动应用的 Go 库，提供简单的消息流处理接口，支持 Kafka、RabbitMQ、NATS、Redis、SQL 等多种发布/订阅实现。

这是一个将 AWS Lambda 视为一等公民的 Node.js/TypeScript 强主见 (opinionated) 框架。它通过装饰器和类型提供 DDD 领域事件、Unit of Work 事务、RFC 7807 问题处理、重试与恢复、OpenTelemetry 追踪以及 SaaS 计费与计量合约等功能。

PAPAI 是一款主动式个人 AI 代理，支持通过自然语言在 Telegram、Mattermost、Discord 和 Kontur Talk 等平台进行任务管理，并与 Kaneo 和 YouTrack 集成。

Hatchet是一个开源编排引擎，用于后台任务、AI代理和持久化工作流。支持Python、TypeScript、Go和Ruby，可通过自托管或Hatchet Cloud部署。功能包括任务重试、定时任务、DAG工作流、实时监控和多租户。