使用 KPL 聚合时的注意事项 - Amazon Kinesis Data Streams

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

使用 KPL 聚合时的注意事项

当结果 Amazon Kinesis Data Streams 记录的序列号架构保持相同时,聚合会形成包含在以 0(零)为开始的聚合 Kinesis Data Streams 记录的 Kinesis Producer Library(KPL)用户记录的索引;然而,只要您不依赖序列号来唯一标识您的 KPL 用户记录,您的代码可忽略它,因为聚合(属于您的 Kinesis Data Streams 记录中的 KPL 用户记录)和后续取消聚合(属于您的 KPL 用户记录中的 Kinesis Data Streams 记录)将自动为您考虑这一方面。无论使用器是使用 KCL 还是 AWS 开发工具包,这一点都适用。要使用此聚合功能,您需要将 KPL 的 Java 部分拉入您的版本中(如果您的使用器是利用 AWS 开发工具包中提供的 API 编写的)。

如果您打算使用序列号作为 KPL 用户记录的唯一标识符,建议您使用 RecordUserRecord 中提供的遵守合约的 public int hashCode()public boolean equals(Object obj) 操作来比较您的 KPL 用户记录。此外,如果您想要检查 KPL 用户记录的子序列号,则可将其转换为 UserRecord 实例并检索其子序列号。

有关更多信息,请参阅消费端取消聚合