开发具有专用吞吐量的自定义消费者（增强的扇出） - Amazon Kinesis Data Streams

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

开发具有专用吞吐量的自定义消费者（增强的扇出）

在 Amazon Kinesis Data Streams 中，可以构建使用增强型扇出功能的消费端。利用此功能，消费端可以从流中接收记录，其数据吞吐量高达每分片 2 MB/秒。此为专用吞吐量，这意味着，使用增强型扇出功能的消费端不必与接收流中数据的其他消费端争夺。Kinesis Data Streams 将流中的数据记录推送到使用增强型扇出功能的消费端。因此，这些消费端无需轮询数据。

重要

您可以为每个流注册多达 20 个消费端，以便使用增强型扇出功能。

下图显示的是增强型扇出功能架构。如果您使用版本 2.0 或更高版本的 Amazon Kinesis 客户端库 (KCL) 来构建使用器，则会将使用KCL器设置为使用增强的扇出来接收来自流中所有分片的数据。如果您使用API来构建使用增强型扇出功能的使用者，则可以订阅单个分片。

显示具有两个分片和两个消费端的增强型扇出功能架构的工作流程图。这两个消费端均使用增强型扇出功能接收来自流的两个分片的数据。

此图显示以下内容：

  • 一个具有两个分片的流。

  • 使用增强型扇出功能接收流中数据的两个消费端：消费端 X 和消费端 Y。这两个消费端均已订阅流的所有分片和所有记录。如果您使用版本 2.0 或更高版本KCL来构建消费者，则KCL会自动为该使用者订阅流中的所有分片。另一方面，如果您使用API来构建消费者，则可以订阅单个分片。

  • 表示消费端用于接收流中数据的增强型扇出功能管道的箭头。增强型扇出功能管道每分片提供高达 2 MB/秒 数据，独立于任何其他管道或消费端的总数量。

主题