轉返後轉返至 KCL 3.x - Amazon Kinesis Data Streams

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

轉返後轉返至 KCL 3.x

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

  1. 執行 KCL 遷移工具

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

步驟 1:執行 KCL 遷移工具

執行 KCL 遷移工具。具有下列命令的 KCL Migration Tool 可轉送至 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 會建立 KCL 3.x 所需的下列 DynamoDB 資源:

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

  • 工作者指標資料表

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

為向前滾動執行 KCL 遷移工具後,請使用 KCL 3.x 將程式碼部署至工作者。遵循 步驟 8:完成遷移 以完成遷移。