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

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

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