适用于 Apache Flink 的亚马逊托管服务发布了新的 Amazon Kinesis Data Streams 连接器
适用于 Apache Flink 的亚马逊托管服务现在为 Amazon Kinesis Data Streams 提供了新的 Apache Flink 连接器。这个开源连接器由 AWS 提供，支持 Apache Flink 2.0，并提供了多项增强功能。它支持在流扩展或缩减期间按顺序读取，支持 Apache Flink 的原生水印，并通过统一的连接器指标提高可观测性。此外，该连接器使用适用于 Java 2.x 的 AWS SDK，后者支持增强的性能和安全功能以及原生重试策略。
Amazon Kinesis Data Streams 是一项无服务器数据流服务，使客户能够捕获、处理和存储任何规模的数据流。借助适用于 Apache Flink 的亚马逊托管服务，您可以更轻松地使用 Apache Flink 实时转换和分析流数据，而无需管理服务器或集群。您可以通过这个新的连接器使用来自 Kinesis Data Stream 源的数据，以便在 Apache Flink 应用程序中进行实时处理，还可以将数据发送回 Kinesis Data Stream 目标。从 Apache Flink 版本 1.19 开始，您可以使用这个新的连接器从 Kinesis 数据流中读取数据。
要了解有关 Apache Flink Amazon Kinesis Data Streams 连接器的更多信息，请访问 Apache Flink 官方文档。您也可以在 GitHub 存储库中查看 Apache AWS 连接器。