发布于: Oct 20, 2023

今天,Amazon Managed Streaming for Apache Kafka (Amazon MSK) 宣布在 MSK 服务控制台中与 Amazon EventBridge 管道集成,让您可以更轻松地将事件从 Apache Kafka 集群发送到超过 14 个 AWS 服务目标(包括 Amazon SQS、Amazon Kinesis Data Streams、Amazon Kinesis Data Firehose,AWS Step Functions、Amazon SNS 或 Amazon EventBridge 事件总线)之一。EventBridge 管道集成还支持 EventBridge API 目的地目标,该目标使用 API 调用将您的事件发送到软件即服务 (SaaS) 应用程序,或您自己在 AWS 内外的应用程序。

从 Kafka 集群中获取数据流非常简单,只需选择集群,从“操作”菜单中选择“创建 EventBridge 管道”,命名连接并选择目标即可。如果需要,您还可以自定义批次大小、批处理窗口和起始位置等。可选的筛选步骤仅允许特定事件流入管道,使用 AWS Lambda、AWS Step Functions、API 目标或 Amazon API Gateway 的可选扩充步骤可用于在事件到达目标之前扩充或转换事件。借助 EventBridge 管道集成,您无需编写、管理和扩展无差别集成代码,从而能够花时间来构建服务而不是连接服务。

首先,在 MSK 控制台中选择一个集群,然后从“操作”菜单中选择“创建 EventBridge 管道”,或者阅读有关 Amazon EventBridge 管道如何帮助您更轻松地集成服务的 AWS 新闻博客文章,了解更多信息。