設定 Kinesis Producer Library - Amazon Kinesis Data Streams

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

設定 Kinesis Producer Library

儘管預設的設定應能適用於大多數使用案例,但您也許想要變更某些預設值,以依照您的需求量身打造 KinesisProducer 的行為。為此,您可以將 KinesisProducerConfiguration 類別的執行個體傳遞給 KinesisProducer 建構函數,例如:

KinesisProducerConfiguration config = new KinesisProducerConfiguration() .setRecordMaxBufferedTime(3000) .setMaxConnections(1) .setRequestTimeout(60000) .setRegion("us-west-1"); final KinesisProducer kinesisProducer = new KinesisProducer(config);

您也可以從屬性檔案載入組態:

KinesisProducerConfiguration config = KinesisProducerConfiguration.fromPropertiesFile("default_config.properties");

您可以替換使用者程序能夠存取的任何路徑和檔案名稱。此外,您亦可對以此方式建立的 KinesisProducerConfiguration 執行個體呼叫 set 方法以自訂組態。

屬性檔案應使用中的名稱來指定參數 PascalCase。這類名稱與 KinesisProducerConfiguration 類別的 set 方法中所使用的名稱相吻。例如:

RecordMaxBufferedTime = 100 MaxConnections = 4 RequestTimeout = 6000 Region = us-west-1

如需有關組態參數使用規則和值限制的詳細資訊,請參閱上的範例組態屬性檔案 GitHub

請注意,一旦 KinesisProducer 初始化,變更使用中的 KinesisProducerConfiguration 執行個體將不會再有任何作用。KinesisProducer​ 目前不支援動態重新配置。