常见问题解答

Oracle 云基础设施 (OCI) 流处理服务是一个全托管、可扩展的持久消息传递解决方案，可用于从多个来源摄取海量连续数据流，以便用户能够实时使用和处理这些数据。所有受支持的 Oracle 云基础设施区域中均可以使用流处理服务。有关详细列表，请访问区域和可用性域页面。

流处理是一种无服务器服务，可分流基础设施管理负载，包括数据流处理所需的网络、存储和配置。您不必担心基础设施的供应、持续维护或安全修补。流处理服务可在三个可用性域之间同步复制数据，从而提供高可用性和数据持久性。在具有单一可用性域的区域，数据将跨三个故障域进行复制。

流处理服务可轻松收集、存储和处理从数百个数据源实时生成的数据。从消息传递到复杂的数据流处理，其使用场景几乎是无限的。下面是流处理的一些可能的使用场景：

• 消息传递：使用流处理来解耦大型系统的组件。生产者和消费者可以使用流处理作为异步消息总线，并按照自己的步调独立行动。
• 指标和日志采集：使用流处理来替代传统的文件抓取方法，这有助于快速将关键运行数据用于索引编制、分析和可视化。
• Web 或移动活动数据采集：使用流处理来从网站或移动应用获取活动数据，例如页面浏览量、搜索量，或者其他用户操作。您可以使用此信息来进行实时监视和分析，以及在数据仓库系统中进行脱机处理和报告。
• 基础设施和应用事件处理：使用流处理作为云组件的统一入口点来报告这些组件的生命周期事件，以便进行审计、核算以及相关活动。

您可以按以下步骤来使用流处理服务：

1. 使用 Oracle 云基础设施控制台或 CreateStream API 操作来创建一个流。
2. 配置生产者以将消息发布至流。请参阅发布消息。
3. 创建使用者以读取和处理流中的数据。请参阅使用消息。

或者，您也可以使用 Kafka API 来生成和使用流。有关更多信息，请参阅使用 Apache Kafka 实现流处理。

通过在流中添加分区，流处理的吞吐量可无限扩展。然而，在使用流处理时应当牢记一些限制：

• 流处理中的邮件的最长保留期为 7 天。
• 可在流中生成的独有消息的最大大小为 1 兆字节 (MB)。
• 每一个分区每秒可处理高达 1 MB 吞吐量，写入请求数量不受任何限制。
• 每一个分区可以支持最高每秒 1 MB 的总数据写入速率和每秒 2 MB 的读取速率。

流处理提供基于流的语义。流语义为每一个分区提供严格的顺序保证、消息重播性、客户端游标以及大规模水平吞吐量。队列并不提供这些功能。队列可以设计为在使用 FIFO 队列时提供顺序保证，但这需要增加一部分性能开销。

流处理是一种经过分区、仅追加日志的消息 ，生产者应用可以在其中写入数据，而使用者应用可以从中读取数据。

流处理池是一种可用于组织和管理流的分组。流处理池支持跨多个流共享配置设置，从而简化操作和运营。例如，用户可以在流处理池上共享自定义加密密钥等安全设置，以便于对池内所有流的数据进行加密。借助流处理池，您还可以限制对流处理池中所有流的互联网访问，从而为流创建专有端点。对于使用流处理的 Kafka 兼容性功能的客户，流处理池将充当虚拟 Kafka 集群的根，从而将针对该虚拟集群的所有操作限制在该流处理池的范围之内。

分区是流处理中的基本吞吐量单位，可在流中实现水平扩展以及并行生产和使用。一个分区提供 1MB/秒的数据输入和 2MB/秒的数据输出。在创建流时，可以根据应用的吞吐量需求来指定所需的分区数量。例如，您可以创建一个具有 10 个分区的流，这样可以在流中实现 10MB/秒的输入吞吐量和 20MB/秒的输出吞吐量。

消息是流中存储的 base64 编码数据单元。可在流的分区中生成的消息的最大大小为 1 MB。

键是用于对相关消息进行分组的标识符。具有相同键的消息将被写入到相同的分区中。流处理可确保特定分区的任何使用者始终能够按照与写入时完全相同的顺序读取该分区的消息。

生产者是可以将消息写入到流中的客户端应用。

使用者是可以从一个或多个流中读取消息的客户端应用。使用者组是一系列可对流中所有分区的消息进行协调的实例。在任何特定时间，来自特定分区的消息只能由组中的单一使用者使用。

游标是指向流中某个位置的指针。该位置可以是指向分区中特定偏移量或时间或者指向组当前位置的指针。

分区中的每个消息都有一个偏移标识符。使用者可以从特定偏移量开始读取消息，并且可以从所选择的任何偏移点进行读取。使用者还可以提交最新处理的偏移，这样在停止工作并重新开始工作时可以继续工作而不会重播或丢失消息。

在默认情况下，流处理服务将同时对动态和静态数据进行加密。流处理服务与 Oracle 云基础设施身份和访问管理服务 (IAM) 实现了全面集成，您可以使用访问策略来选择性地为用户和用户组授予权限。在使用 REST API 时，您还可以通过支持 HTTPS 协议的 SSL 端点，从流处理中 PUT 和 GET 数据。此外，流处理服务还提供全面的租户级数据隔离，而不会产生任何“坏邻居”问题。

流处理数据在静态和动态状态均经过加密，同时确保消息完整性。您可以让 Oracle 来管理加密，或者如果需要满足特定的合规性或安全性标准，则可以使用 Oracle Cloud Infrastructure Vault 来安全存储和管理自己的加密密钥。

如果要在“Oracle Keys 提供的加密”和“使用 Customer Managed Keys 管理的加密”之间切换，则可以随时编辑流池的数据加密设置。流处理并不会对该活动的执行次数施加任何限制。

流处理服务与 Oracle 云基础设施 IAM 实现了全面集成。每个流都会分配一个隔离区。用户可以指定基于角色的访问控制策略，这些策略可用于描述租户、隔离区或单个流级别的细粒度规则。

指定访问策略的形式如下："Allow <subject> to <verb> <resource-type> in <location> where <conditions>"。

Kafka 协议的身份验证使用身份验证令牌和 SASL/PLAIN 机制。您可以在控制台用户详细信息页面上生成令牌。有关详细信息，请参阅使用身份令牌。我们建议您创建一个专用组/用户，并为该组授予在适当的隔离专区或租户中管理流的权限。随后，您可以为所创建的用户生成身份验证令牌，并在 Kafka 客户端配置中使用。

专有端点将限制对租户内指定的虚拟云网络 (VCN) 的访问，因此无法通过互联网访问其流。专有端点会将 VCN 内的专有 IP 地址与流池相关联，从而允许流式传输流量以避免遍历互联网。要为流处理创建专有端点，则在创建流池时需要使用专有子网访问 VCN。有关更多信息，请参阅关于专有端点和 VCN 与子网。

您可以将流的内容直接写入到对象存储桶中，这通常可以将数据长期持久存储在流中。这可以使用 Kafka Connect for S3 和流处理来实现。有关更多信息，请参阅使用 Oracle 流处理服务发布对象存储博文。

您可以从 Oracle 自治事务处理实例的表中提取数据。有关更多信息，请参阅使用 Kafka Connect、Oracle 流处理服务和自治数据库博文。

您可以使用 Kafka SDK 从流处理服务生成和使用消息，还可以使用 Micronaut 对 Kafka 的内置支持。有关更多信息，请参阅通过 Micronaut 的 Kafka 支持和 Oracle 流处理服务轻松实现消息传递博文。

有关更多信息，请参阅将来自 MQTT 代理的物联网数据提取到 OCI-Oracle 流处理服务、OCI-Kafka Connect Harness 和 Oracle Kubernetes 引擎中博文。

Oracle GoldenGate for Big Data 现已与流处理服务相集成，并且已通过认证。有关更多信息，请参阅 Oracle GoldenGate for Big Data 文档中的连接至 Oracle 流处理服务。

您需要使用 Kafka JDBC Sink Connect 直接将流数据传输到 Oracle ADW 业务数据平台中。

• 使用 Kafka Connect、Oracle 流处理服务和自治数据库博文阐述了如何使用 Kafka Connect 源连接器将 Oracle ADW 业务数据平台中的数据推送到流中。您需要反向操作，也就是 Sink 连接器。
• OSS 数据近实时传输至 ADW 博文阐述了如何使用包含对象存储路径的外部表从 Oracle ADW 业务数据平台中获取数据。

流处理服务使用简单的即用即付定价模式，可确保您只为所使用的资源付费，而无需任何前期费用。定价维度包括：

• GET/PUT 请求价格（数据传输量 (GB)）
• 存储价格，取决于数据的保留小时数 - 每小时存储量 (GB)

有关最新定价信息，请参阅流处理产品页面。

流处理服务采用行业领先的定价模式，您只需在使用服务时付费。也就是说，您无需为未使用的资源支付额外的费用。

将数据移入和移出流媒体服务不需要支付额外费用。此外，用户也可以利用强大的 Service Connector Hub 以无服务器方式将数据移入和移出流媒体服务，而不需要支付额外费用。

目前，流媒体服务并未包含在免费套餐中。

Oracle 云基础设施流处理服务可保证每月正常运行时间至少为 99.9％。适用 Oracle 云基础设施流处理服务的每月正常运行时间百分比的计算方式是从 100％ 中减去日历月中的不可用百分比。

请参阅 Oracle PaaS 和 IaaS 公有云服务支柱文档的第 2.7.1.6.32 节“Oracle 云基础设施 - 流处理服务”，详细了解 SLA 的所有条款和条件以及服务储值资格。

身份与访问管理可允许您控制哪些人有权访问您的云资源。要使用 Oracle 云基础设施资源，无论您使用控制台还是随带 SDK、CLI 或其他工具的 REST API，都需要在管理员编写的策略中为您指定所需的访问类型。访问策略的指定形式如下：

Allow <subject> to <verb> <resource-type> in <location> where <conditions>

租户的管理员可以使用策略

Allow group StreamAdmins to manage streams in tenancy

这将允许指定的 StreamAdmins 组执行一切操作，包括创建、更新、列出以及删除流及其相关资源。但是，您始终可以指定更加精细化的策略，确保只有组中的选定用户才有资格执行可针对特定流执行的部分活动。如果您刚开始接触策略，请参阅策略快速入门和常见策略。如果您希望更加深入的了解如何为流处理服务编写策略，请参阅 IAM 策略参考中的流处理服务详细信息。

您可以使用 Oracle 云基础设施资源管理器 或适用于 Oracle 云基础设施的 Terraform 提供程序来供应流及其所有相关组件，例如 IAM 策略、分区、加密设置等。有关 Terraform 提供程序的详细信息，请参阅流处理服务的 Terraform 主题。

在创建流时，您需要指定流具有多少个分区。应用的预期吞吐量可以帮助您确定流的分区数量。您可以将平均消息大小乘以每秒写入的最大消息数来估算预期吞吐量。由于单一分区限制为每秒 1 MB 的写入速率，因此更高的吞吐量需要额外的分区来避免节流。为了帮助您管理应用高峰，我们建议所分配的分区略高于最大吞吐量。

您可以在创建流时创建分区，可选择使用控制台或采用程序化方式。

控制台 UI：

程序化方式：

创建流

CreateStreamDetails streamDetails =

        CreateStreamDetails.builder()

                .compartmentId(compartmentId)

                .name(streamName)

                .partitions(partitions)

                .build();

SDK 中提供了一个更加详细的示例。

流处理服务可在内部管理分区，而无需您手动管理。用户无法直接删除分区。在删除流时，与该分区相关联的所有分区都将被删除。

Oracle 云基础设施流的吞吐量由分区定义。一个分区提供 1MB/秒的数据输入和 2MB/秒的数据输出。

可以通过添加更多分区来扩展 Oracle 云基础设施流的吞吐量。流可以容纳的分区数量没有理论上限。然而，每一个 Oracle 云基础设施租户都将通用储值类型帐户的默认分区限制设置为 5。如果需要更多分区，您可以随时请求增加服务限制。

您可以通过以下步骤来请求增加服务限制：

1. 在控制台的右上角，打开用户菜单并单击 租户： <tenancy_name> .
   
   
2. 单击服务限制，然后单击请求增加服务限制。
   
   
3. 填写表单，在服务类别中选择其他，并在资源中选择其他限制。在请求理由中，指明请求增加租户中的流处理服务的分区数。

在创建流时，请牢记以下优秀实践：

• 流名称在流池中应当是唯一的。也就是说，您只能在同一隔离区中创建两个具有相同名称的流，但前提是它们位于不同的流池中。
• 创建流后，无法更改其中的分区数量。我们建议所分配的分区略高于您的最大吞吐量。这将帮助您管理应用高峰。
• 创建流后，无法更改其保留时长。默认情况下，流中的数据将存储 24 小时。但是可以配置将数据保留 24 到 168 小时之间的任意时长。流中存储的数据量不会对流的性能产生任何影响。

当流创建完成并处于“活动”状态之后，您就可以开始生成消息了。您可以使用控制台或通过 API 来将消息生成到流中。

对于控制台：转至控制台的流处理服务区域，该区域位于 Solutions and Platform > Analytics 选项卡中。如果已经创建了流，请在隔离区中选择一个流，并导航至“流详细信息”页面。单击控制台上的“生成测试消息”按钮。这将为消息随机分配一个分区键，并且将写入到流的分区中。您可以单击加载消息按钮，并在最近消息中查看消息。

对于 API：您可以使用 Oracle 云基础设施流处理服务 API 或 Kafka API 来生成流。消息将发布到流中的一个分区。如果有多个分区，则可以指定一个键来选择将消息发送至哪些分区，如果不指定键，则流处理服务将通过生成 UUID 来为您分配一个键，然后将消息发送至随机分区。这将确保没有键的消息均匀分布于所有分区中。但是，我们建议您在任何情况下都要指定一个消息键，以便于可以显式控制数据的分区策略。

有关使用流处理 SDK 将消息生成到流中的示例，请参阅文档。

当使用 Oracle 云基础设施 API 生成消息时，分区逻辑将由流处理服务控制。这称为服务器端分区。作为用户，您可以根据键来选择要发送到哪一个分区。键将转换为散列形式，并且最终值将用于确定要将消息发送到的分区号。具有相同键的消息将进入到相同的分区中。具有不同键的消息可能会进入到不同的分区中，也可能会进入到相同的分区中。

但是，如果使用 Kafka API 来生成流，则分区将由 Kafka 客户端控制，并且 Kafka 客户端中的分区程序将负责分区逻辑。这称为客户端分区。

为了确保均匀分发消息，您需要一个有效的消息键值。要创建一个值，请考虑流处理数据的选择性和基数。

• 基数：请考虑可根据特定用例生成的唯一键的总数。更高的键基数通常意味着更好的分布。
• 选择性：请考虑每一个键的消息数量。更高的选择性意味着每一个键有更多消息，这可能会导致热点。

始终以高基数和低选择性为目标。

流处理服务可保证在分区内进行线性化的读取和写入操作。如果要确保具有相同值的消息进入相同的分区，则应当对这些消息使用相同的键。

分区提供 1MB/秒 的数据输入速率，每秒支持多达 1000 条 PUT 消息。因此，如果记录大小小于 1KB，则分区的实际数据输入速率将小于 1MB/少，这将受到每秒最大 PUT 消息数量的限制。我们建议您批量生成消息，原因如下：

• 这将减少发送至服务的 put 请求的数量，从而避免节流。
• 这有助于提高吞吐量。

批量消息的大小不应超过 1 MB。如果超过此限制，则会触发节流机制。

您可以使用块或通过 Oracle 云基础设施对象存储来发送消息。

• 块：您可以将大型负载拆分为流处理服务可以接受的多个较小的块。块采用与普通非分块消息相同的方式存储在服务中。唯一的区别在于，使用者需要保留这些块并收集所有块来组合成消息。分区中的块可以与普通消息交织在一起。
• 对象存储：大型负载放置在对象存储中，并且仅传输指向该数据的指针。接收器识别出此类指针负载，透明地从对象存储中读取数据，并将其提供给最终用户。

当生产者以大于每秒 1MB 的速度生产消息时，请求将受到限制，并向客户端返回 429, Too Many Requests 错误，这表示每个分区每秒收到的请求过多。

使用者是可从一个或多个流中读取消息的实体。此实体可以单独存在，也可以是使用者组的一部分。要使用消息，您需要创建一个游标，然后使用该游标来读取消息。游标将指向流中某个位置。该位置可以是分区中的特定偏移量或时间或者组的当前位置。根据要读取的位置，可以选择使用各种不同的游标类型：TRIM_HORIZON, AT_OFFSET, AFTER_OFFSET、AT_TIME 和 LATEST.

有关更多信息，请参阅使用消息的相关文档。

GetMessagesRequest 类的 getLimit( ) 方法将返回最大消息数量。您可以指定 10000 以内的任何值。该服务默认将返回尽可能多的消息。请考虑您的平均消息大小，以避免超出流的吞吐量。流处理 GetMessages 批量大小取决于为特定流生成的平均消息大小。

流处理服务为使用者提供“至少一次”的交付语义。我们建议由使用者应用来处理重复项。例如，当之前非活动的使用者组实例重新加入组并开始使用之前所分配实例尚未提交的消息时，可能会发生重复删除处理。

如果生产速度快于使用速度，则使用者就会落后。要确定您的使用者是否落后，可以使用消息的时间戳。如果使用者落后，请考虑生成一个新使用者来接管第一个使用者的某些分区。如果您在单一分区上落后，则无法恢复。

请考虑以下选项：

• 增加流中的分区数量。
• 如果问题是由热点引起的，那么请更改消息键策略。
• 减少消息处理时间，或并行处理请求。

如果希望了解特定分区中还有多少消息待使用，那么请使用 LATEST 类型的游标，获取下一条已发布消息的偏移量，并使用与您的偏移量相对应的增量。由于我们没有密集偏移，因此您只能得到一个粗略的估计。然而，如果生产者停止生产，那么您将无法获取该信息，因为您永远都无法获取下一条已发布消息的偏移量。

可以将使用者配置为组成员，以组成员的身份来使用消息。流分区在组成员间分配，以便来自任何单一分区的消息仅会发送至单一使用者。当使用者加入或离开使用者组之后，分区分配会重新平衡。有关更多信息，请参阅使用者组的相关文档。

使用者组具有以下优势：

• 使用者组中的每一个实例都将从一个或多个“自动”分配的分区接收消息，而其他实例（分配给不同的分区）则不会收到相同的消息。这样一来，通过让一个实例仅读取一个分区，我们可以将实例数量扩展为分区数量。在这种情况下，加入该组的新实例处于空闲状态，而不会分配给任何分区。
• 实例作为 不同使用者组 的一部分意味着将提供一种 发布-订阅模式，在该模式中，来自分区的消息将被发送至跨不同组的所有实例。
  在同一个使用者组中，规则如下图所示：
  
  
  在不同的组中，实例将收到相同的消息，如下图所示：
  
  当分区内的消息与采用不同方式处理这些消息的不同应用相关时，此规则将非常有用。我们希望所有相关应用均从分区接收所有相同的消息。
• 当某实例加入一个组时，如果有足够的分区可用（即尚未达到每一个分区一个实例的限制），则会开始重新均衡。分区重新分配给当前实例，再加上新实例。同样，如果某实例离开组，则会将分区重新分配给其余实例。
• 系统将自动管理偏移提交。

每一个流最多支持 50 个使用者组。使用者组是临时的。如果在流的保留期内未使用，那么这些使用者组就会消失。

流处理服务的以下要素会有超时：

• 游标：只要您继续使用消息，就不需要创建游标。如果消息使用停止超过 5 分钟，则需要重新创建游标。
• 实例：如果某实例停止使用消息的时间超过 30 秒，则会将其从使用者组中删除，并将其分区重新分配给另一个实例。这称为重新均衡。

在重新均衡流程中，属于同一使用者组的一组实例通过协调，确保拥有属于特定流的一组互斥分区。当使用者组成功完成重新均衡操作时，流中的每一个分区均归该组内的一个或多个使用者实例所有。

当使用者组的实例因无法发送心跳超过 30 秒而变为非活动状态或流程终止时，使用者组内将触发重新均衡活动。这是为了处理非活动实例之前使用的分区，并将其重新分配给活动实例。同样，当使用者组中之前非活动的实例加入该组时，这将触发重新均衡流程分配一个分区并从中开始使用。当实例重新加入该组时，流处理服务并不会保证将该实例重新分配给同一分区。

要从故障中恢复，您需要存储针对每一个分区所处理的最后一条消息的偏移量，以便于在需要重新启动使用者时可从该消息开始使用。

注意：请勿存储游标；它们将在 5 分钟后到期。

我们并不针对所处理的最后一条消息的偏移量的存储方式提供任何指导，您可以使用所需要的任何方法。例如，您可以将游标存储在另一个流上，或者也可以存储在 VM 上的文件中或对象存储桶中。当使用者重新启动时，读取所处理的最后一条消息的偏移量，然后创建 AFTER_OFFSET 类型的游标并指定刚获取的偏移量。

流处理服务提供了一个 Kafka 端点，可供现有基于 Apache Kafka 的应用使用。要实现全托管式 Kafka 体验，只需进行配置更改即可。流处理服务的 Kafka 兼容性为运行您自己的 Kafka 集群提供了一种替代方案。流处理服务支持 Apache Kafka 1.0 和更高版本的客户端，并且可以与现有 Kafka 应用、工具和框架协同作业。

使用 Kafka 应用的客户只需更改其 Kafka 配置文件的以下参数，即可迁移至流处理服务。

security.protocol:SASL_SSL

sasl.mechanism:PLAIN

sasl.jaas.config:org.apache.kafka.common.security.plain.PlainLoginModule required username="{username}" password="{pwd}";

bootstrap.servers:kafka.streaming.{region}.com:9092

# Application settings

topicName:[streamOcid]

要结合使用 Kafka 连接器与流处理服务，请使用控制台或命令行接口 (CLI) 创建一个 Kafka Connect 配置。流处理 API 将调用这些配置harnesses。特定隔离区中创建的 Kafka Connect 配置仅适用于同一隔离区中的流。您可以使用多个具有相同 Kafka Connect 配置的 Kafka 连接器。如果需要在单独的隔离区中生成或使用流，或者需要更大的容量来避免达到 Kafka Connect 配置上的节流限制（例如，连接器过多或使用连接器的员工过多），则可以创建更多的 Kafka 连接器配置。

流处理服务的 Kafka Connect 兼容性意味着您可以利用许多现有的第一方和第三方连接器将数据从源移至目标。适用于 Oracle 产品的 Kafka 连接器包括：

• Oracle 云基础设施对象存储（使用 Kafka Connect for S3）
• Kafka Connect Amazon S3 源连接器，适用于生产者
• Kafka Connect Amazon S3 sink 连接器，适用于使用者
• Oracle 集成云
• Oracle 数据库（使用 Kafka Connect JDBC）
• Oracle GoldenGate

有关第三方 Kafka 源连接器和 sink 连接器的完整列表，请参阅官方 Confluent Kafka 平台。

流处理服务与 Oracle 云基础设施监视服务实现了全面集成。在控制台中选择要监视的流。在 Stream Details 页面中，导航至 Resources 区域，点击 Produce Monitoring Charts 监视生产者请求，或者点击 Consume Monitoring Charts 监视使用者端指标。这些指标适用于流层面，而不是分区层面。有关受支持流指标的描述，请参阅文档。

控制台中可用的每一个指标均提供以下统计信息：.

• 费率、和值和均值
• 最小值、最大值和计数
• P50、P90、P95、P99 和 P99.9

这些统计信息按以下时间间隔提供：

• 汽车
• 1 分钟
• 5 分钟
• 1 小时

对于生产者，请考虑根据以下指标设置警报：

• Put Messages Latency：延迟增加意味着消息发布时间更长，这可能表示存在网络问题。
• Put Messages Total Throughput：
  • 总吞吐量的大幅增长可能表示将达到每个分区每秒 1 MB 的限制，并且该事件将触发限制机制。
  • 大幅减少可能意味着客户生产者遇到问题或将要停止。
• Put Messages Throttled Records：当消息受到限制时，获取通知非常重要。
• Put Messages Failure：如果 put 消息启动失败，则需要获取通知，以便于运营团队能够开始调查原因。

对于使用者，请考虑根据以下指标设置相同的警报：

• Get Messages Latency
• Get Messages Total Throughput
• Get Messages Throttled Requests
• Get Messages Failure

当流处于活动状态时，其运行状况良好。如果您可以将消息生成到流中，并获得成功响应，则表示流运行状况良好。当流中生成数据后，使用者可以在配置的保留期内对其进行访问。如果 GetMessages API 调用返回更高级别的内部服务器错误，则表示该服务不正常。

运行状况良好的流也具有正常的指标：

• Put Messages Latency 较低。
• Put Messages Total Throughput 接近每个分区每秒 1 MB。
• Put Messages Throttled Records 接近于 0。
• Put Messages Failure 接近于 0。

• Get Messages Latency 较低。
• Get Messages Total Throughput 接近每分区每秒 2 MB。
• Get Messages Throttled Requests 接近于 0。
• Get Messages Failure 接近于 0。

节流表示该流无法处理任何新的读取或写入操作。超过以下阈值时将激活节流机制：

• GetMessages：每秒五次调用或每个分区每秒 2 MB
• PutMessages：每个分区每秒 1 MB
• 管理和控制平台操作，例如 CreateCursor 和 ListStream 等：每个流每秒五次调用

有关 API 错误的详细信息，请参阅文档。