Amazon Kinesis Data Streams
开发人员指南
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 Amazon AWS 入门

配置 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。

属性文件应使用以帕斯卡拼写法书写的名称来指定参数。这些名称将与 KinesisProducerConfiguration 类中的设置方法中使用的名称匹配。例如:

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

有关配置参数使用规则和值限制的更多信息,请参阅 在 GitHub 上示例配置属性的文件

请注意,初始化 KinesisProducer 后,更改已使用的 KinesisProducerConfiguration 实例不会产生进一步的影响。KinesisProducer 当前不支持动态重新配置。