在 Kinesis 串流任務中使用強化廣發功能 - AWS 連接詞

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

在 Kinesis 串流任務中使用強化廣發功能

強化廣發功能取用者能夠從 Kinesis 串流接收記錄,其專用輸送量可能高於一般取用者。這是透過最佳化用來提供資料給 Kinesis 取用者 (例如您的任務) 的傳輸通訊協定來完成。如需有關 Kinesis 強化廣發功能的詳細資訊,請參閱 Kinesis 文件

在強化廣發功能模式下,maxRecordPerReadidleTimeBetweenReadsInMs 連線選項不再適用,因為使用強化廣發功能時無法設定這些參數。重試的組態選項會如上所述執行。

使用下列程序來啟用和停用串流任務的強化廣發功能。您應該為每個會使用串流資料的任務註冊串流取用者。

若要在任務上啟用強化廣發功能使用服務:
  1. 使用 Kinesis API 為您的任務註冊串流取用者。按照 Kinesis 文件中的說明,使用 Kinesis Data Streams API 向強化廣發功能註冊取用者。您只需要按照第一步:呼叫 RegisterStreamConsumer 進行操作。您的請求應傳回一個 ARN,即 consumerARN

  2. 在連線方法引數中將連線選項 fanoutConsumerARN 設定為 consumerARN

  3. 重新啟動您的任務。

若要停用任務上的強化廣發功能取用服務:
  1. 從您的方法呼叫中移除 fanoutConsumerARN 連線選項。

  2. 重新啟動您的任務。

  3. 按照 Kinesis 文件中的說明取消註冊取用者。這些說明適用於主控台,但也可以透過 Kinesis API 來實現。如需有關透過 Kinesis API 進行串流取用者取消註冊的詳細資訊,請參閱 Kinesis 文件中的 DeregisterStreamConsumer