本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
配置 Amazon Kinesis 制作器库
虽然默认设置应适用于大多数使用案例,但您可能想更改部分默认设置以定制 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 方法来自定义 config。
属性文件应使用中的名称来指定参数 PascalCase。这些名称将与 KinesisProducerConfiguration 类中的设置方法中使用的名称匹配。例如:
RecordMaxBufferedTime = 100
MaxConnections = 4
RequestTimeout = 6000
Region = us-west-1有关配置参数使用规则和值限制的更多信息,请参阅上的配置属性文件示例 GitHub
请注意,初始化 KinesisProducer 后,更改已使用的 KinesisProducerConfiguration 实例不会产生进一步的影响。KinesisProducer 当前不支持动态重新配置。