配置 Amazon Kinesis Producer Library - Amazon Kinesis Data Streams
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

配置 Amazon 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 当前不支持动态重新配置。