回復後向前滾動至 KCL 3.x - Amazon Kinesis Data Streams

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

回復後向前滾動至 KCL 3.x

本主題說明在復原後將消費者轉返至 KCL 3.x 的步驟。當您需要向前推進時,必須經歷兩步驟程序:

  1. 執行KCL遷移工具

  2. 使用 KCL 3.x 部署程式碼。

步驟 1:執行KCL遷移工具

執行KCL遷移工具。KCL 具有下列命令的遷移工具,可轉送至 KCL 3.x:

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

參數

  • --region:將 取代<region>為您的 AWS 區域。

  • --application_name:如果您使用協調員狀態資料表的預設名稱,則需要此參數。如果您已為協調器狀態資料表指定自訂名稱,您可以省略此參數。將 取代<applicationName>為您實際KCL的應用程式名稱。如果未提供自訂名稱,則工具會使用此名稱衍生預設資料表名稱。

  • --coordinator_state_table_name (選用):當您在KCL組態中為協調器狀態資料表設定自訂名稱時,需要此參數。如果您使用的是預設資料表名稱,則可以省略此參數。<coordinatorStateTableName> 以您為協調器狀態資料表指定的自訂資料表名稱取代 。

在向前滾動模式下執行遷移工具後, 會KCL建立 3.x KCL 所需的下列 DynamoDB 資源:

  • 租用資料表上的全域次要索引

  • 工作者指標資料表

步驟 2:使用 KCL 3.x 部署程式碼

執行適用於轉期的KCL遷移工具後,請使用 KCL 3.x 將程式碼部署至工作者。遵循 步驟 8:完成遷移 以完成遷移。