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