适用于 Amazon EventBridge 的 Kafka 连接器 - Amazon EventBridge

适用于 Amazon EventBridge 的 Kafka 连接器

EventBridge 的 Kafka 接收器连接器可将来自一个或多个 Kafka 主题的记录转换为事件，并将这些事件发送到您选择的事件总线。

该连接器具备以下功能：

  • 可自定义的 Kafka 记录到事件类型的映射。

    您可以自定义 Kafka 主题名称与事件类型的映射关系，包括使用 JsonPath 表达式。这使您可以将连接器配置为从多个 Kafka 主题中使用，并筛选发送到指定事件总线的事件。

  • 将大型事件有效载荷分载到 Amazon S3。

    Kafka 主题可包含超过 PutEvents 大小限制的记录。您可以将连接器配置为在调用 PuteVents 之前将事件分载到 Amazon S3。

  • 对死信主题的支持。

  • 对 Avro 和协议缓冲区（Protobuf）的架构注册表支持

Kafka Connector for Amazon EventBridge 可在 GitHub 上找到。有关使用 Amazon MSK Connect 安装和配置连接器的详细说明，请参阅《Amazon Managed Streaming for Apache Kafka 开发人员指南》中的 Set up EventBridge Kafka sink connector for Amazon MSK Connect。