寻求AWS EventBridge替代方案：支持event bus、rules等核心功能

1. Knative Eventing #

• 完全覆盖需求的核心能力：
  • 内置Event Bus（Broker组件），支持创建多租户、隔离的事件总线，适配不同业务场景
  • **规则（Rules）**通过Trigger组件实现，支持基于事件属性的过滤、路由，规则配置在事件层而非消费者端
  • **目标（Targets）**可对接K8s服务、Serverless函数、消息队列等多种类型的服务
  • 提供HTTP API、SDK等多种方式发送事件到总线
  • 结合CronJobSource组件，支持基于Cron表达式的定时任务调度，自动触发事件
• 优势：云原生架构，基于Kubernetes，完全开源无供应商锁定，生态完善，可无缝集成现有K8s集群

2. NATS JetStream #

• 事件总线：以JetStream的Stream作为Event Bus，支持事件持久化与多消费者模式
• 规则路由：通过NATS的Subject过滤、消费者规则实现服务端的事件路由，支持基于主题、事件内容的匹配逻辑，无需消费者处理规则
• 目标对接：可将事件路由到NATS消费者、HTTP端点、外部服务等目标
• 事件发送：通过NATS客户端或HTTP API快速发送事件
• 定时调度：支持内置定时发布功能，或配合外部Cron工具调用API实现定时事件触发
• 优势：轻量级、部署简单、性能优异，适合中小规模事件驱动场景，完全开源无锁定

3. Apache Pulsar + Pulsar Functions #

• 事件总线：利用Pulsar的Topic/Namespace机制构建多租户、分区化的Event Bus，支持大规模事件流处理
• 规则处理：通过Pulsar Functions在集群端实现事件过滤、转换、路由规则，避免消费者端的规则逻辑
• 目标适配：Pulsar Functions可将处理后的事件转发到Pulsar Topic、HTTP服务、数据库等目标
• 事件发送：通过Pulsar客户端、REST API发送事件
• 定时调度：Pulsar Functions原生支持Cron表达式触发，可直接配置定时任务生成事件
• 优势：分布式高可用架构，兼容Kafka生态，适合超大规模事件场景，无供应商锁定

4. 开源事件编排框架 EventFlow #

• 专为事件驱动架构设计，开箱即用的Event Bus、规则引擎、目标路由能力
• 规则配置：支持可视化或代码定义基于事件内容的复杂路由规则，无需消费者参与规则处理
• 目标对接：兼容HTTP服务、消息队列、数据库、函数计算等多种目标类型
• 事件发送：提供REST API、多语言SDK发送事件
• 定时调度：内置定时任务模块，支持Cron表达式触发事件
• 优势：专注事件编排，学习成本低，完全开源无锁定

Kafka 场景的优化方案 #

如果倾向于使用Kafka，可通过以下方式弥补规则配置的不足：

• 部署Kafka Streams：在集群端实现事件过滤、路由逻辑，将匹配规则的事件转发至指定Topic，消费者仅需监听目标Topic
• 结合Debezium + Kafka Connect + 规则引擎：在Connect层接入规则引擎（如Drools）处理事件路由，避免消费者端处理规则
• 引入Apache Camel：作为中间层配置路由规则，接收Kafka事件并转发到目标服务，实现集中式规则管理

内容的提问来源于stack exchange，提问作者luickx