回滚后前滚到 KCL 3.x - Amazon Kinesis Data Streams
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

回滚后前滚到 KCL 3.x

本主题介绍在回滚后将消费端前滚到 KCL 3.x 的步骤。当您需要前滚时,必须完成一个由两步组成的过程:

  1. 运行 KCL Migration Tool

  2. 使用 KCL 3.x 部署代码。

步骤 1:运行 KCL 迁移工具

运行 KCL Migration Tool。具有以下命令的 KCL 迁移工具,用于前滚到 KCL 3.x:

python3 ./KclMigrationTool.py --region <region> --mode rollforward [--application_name <applicationName>] [--coordinator_state_table_name <coordinatorStateTableName>]

参数

  • --region:将 <region> 替换为您的 Amazon Web Services 区域。

  • --application_name:如果您为协调器状态表使用默认名称,则需要此参数。如果您已为协调器状态表指定了自定义名称,则可以忽略此参数。将 <applicationName> 替换为实际的 KCL 应用程序名称。如果未提供自定义名称,该工具将使用此名称来派生默认表名称。

  • --coordinator_state_table_name(可选):如果您在 KCL 配置中为协调器状态表设置了自定义名称,则需要此参数。如果您使用的是默认表名称,则可以忽略此参数。将 <coordinatorStateTableName> 替换为您为协调器状态表指定的自定义表名称。

在前滚模式下运行迁移工具后,KCL 会创建 KCL 3.x 所需的以下 DynamoDB 资源:

  • 租约表上的全局二级索引

  • 工作线程指标表

步骤 2:使用 KCL 3.x 部署代码

运行 KCL 迁移工具以进行前滚后,使用 KCL 3.x 将代码部署到工作线程。按照 步骤 8:完成迁移 完成迁移。