回滚后前滚到 KCL 3.x
本主题介绍在回滚后将消费端前滚到 KCL 3.x 的步骤。当您需要前滚时,必须完成一个由两步组成的过程:
-
使用 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:完成迁移 完成迁移。