发布于: May 31, 2023

今天,AWS 宣布推出适用于 Apache Kafka Connect 的 Amazon EventBridge 开源连接器。借助此连接器,您可以将 EventBridge 集成到 Kafka Connect 环境,以便将来自 Kafka 主题的事件传送到 EventBridge 事件总线。它还包含很多有用的功能,例如对 Avro、Protobuf 和 JSON 的架构注册表支持,使用多个 Kafka 主题以及基于 IAM 角色的身份验证。

Amazon EventBridge 是一个无服务器事件总线服务,使用该服务,您可以路由您自己的应用程序、第三方 SaaS 应用程序和其他 AWS 服务之间的事件,从而创建可扩展的事件驱动型应用程序。借助新的 EventBridge 连接器,Kafka Connect 用户可以轻松筛选和响应来自 Kafka 的业务关键型事件,而且无需编写集成代码即可将事件无缝传送到 EventBridge 中 35 个以上的支持目标合作伙伴集成。其他用例包括通过总线到总线路由将来自 Kafka 的事件传送到多个业务部门,出于复制数据目的或在云迁移期间流式传输来自本地环境的事件,以及轻松调用跨账户或跨区域目标。新的 EventBridge 连接器可以部署在安装的 Apache Kafka Connect 上,包括 Amazon MSK Connect。 

要开始使用该连接器,请从 Github 存储库下载最新版本,将其添加到 Kafka Connect 插件目录路径,然后使用 Kafka Connect Rest API 创建连接器。如果您使用的是 Amazon MSK,请参阅开发人员指南来创建自定义连接器。要开始使用 Amazon EventBridge,请访问我们的文档