本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
在 Kinesis 串流任務中使用強化廣發功能
強化廣發功能取用者能夠從 Kinesis 串流接收記錄,其專用輸送量可能高於一般取用者。這是透過最佳化用來提供資料給 Kinesis 取用者 (例如您的任務) 的傳輸通訊協定來完成。如需有關 Kinesis 強化廣發功能的詳細資訊,請參閱 Kinesis 文件。
在強化廣發功能模式下,maxRecordPerRead
和 idleTimeBetweenReadsInMs
連線選項不再適用,因為使用強化廣發功能時無法設定這些參數。重試的組態選項會如上所述執行。
使用下列程序來啟用和停用串流任務的強化廣發功能。您應該為每個會使用串流資料的任務註冊串流取用者。
若要在任務上啟用強化廣發功能使用服務:
-
使用 Kinesis API 為您的任務註冊串流取用者。按照 Kinesis 文件中的說明,使用 Kinesis Data Streams API 向強化廣發功能註冊取用者。您只需要按照第一步:呼叫 RegisterStreamConsumer 進行操作。您的請求應傳回一個 ARN,即
consumerARN
。 -
在連線方法引數中將連線選項
fanoutConsumerARN
設定為consumerARN
。 -
重新啟動您的任務。
若要停用任務上的強化廣發功能取用服務:
從您的方法呼叫中移除
fanoutConsumerARN
連線選項。重新啟動您的任務。
-
按照 Kinesis 文件中的說明取消註冊取用者。這些說明適用於主控台,但也可以透過 Kinesis API 來實現。如需有關透過 Kinesis API 進行串流取用者取消註冊的詳細資訊,請參閱 Kinesis 文件中的 DeregisterStreamConsumer。