26.3. Spring Boot Auto-Configuration
组件支持 17 个选项,如下所示。
名称 | 描述 | 默认 | 类型 |
---|---|---|---|
camel.component.aws-kinesis.access-key | Amazon AWS 访问密钥 | 字符串 | |
camel.component.aws-kinesis.configuration.access-key | Amazon AWS 访问密钥 | 字符串 | |
camel.component.aws-kinesis.configuration.amazon-kinesis-client | Amazon Kinesis 客户端用于此端点的所有请求 | AmazonKinesis | |
camel.component.aws-kinesis.configuration.iterator-type | 定义 Kinesis 流中的什么位置以开始获取记录 | ShardIteratorType | |
camel.component.aws-kinesis.configuration.max-results-per-request | 在每个轮询中获取的最大记录数 | 1 | 整数 |
camel.component.aws-kinesis.configuration.proxy-host | 在实例化 DDBStreams 客户端时定义代理主机 | 字符串 | |
camel.component.aws-kinesis.configuration.proxy-port | 在实例化 DDBStreams 客户端时定义代理端口 | 整数 | |
camel.component.aws-kinesis.configuration.region | Kinesis 客户端需要工作的区域 | 字符串 | |
camel.component.aws-kinesis.configuration.secret-key | Amazon AWS Secret Key | 字符串 | |
camel.component.aws-kinesis.configuration.sequence-number | 从开始轮询的序列号。如果iteratorType 设置为 AFTER_SEQUENCE_NUMBER 或 AT_SEQUENCE_NUMBER | 字符串 | |
camel.component.aws-kinesis.configuration.shard-closed | 定义在分片关闭时的行为。可能的值有 ignore、silent 和 fail。如果忽略了消息,并且消费者将从一开始重新启动,不会记录下来,并且消费者从一开始就开始记录,而消费者将从开始失败,则会引发 ReachedClosedStateException。 | KinesisShardClosed StrategyEnum | |
camel.component.aws-kinesis.configuration.shard-id | 定义 Kinesis 流中要获取记录的 shardId | 字符串 | |
camel.component.aws-kinesis.configuration.stream-name | 流的名称 | 字符串 | |
camel.component.aws-kinesis.enabled | 启用 aws-kinesis 组件 | true | 布尔值 |
camel.component.aws-kinesis.region | Amazon AWS Region | 字符串 | |
camel.component.aws-kinesis.resolve-property-placeholders | 启动时,组件是否应自行解析属性占位符。只有 String 类型的属性才能使用属性占位符。 | true | 布尔值 |
camel.component.aws-kinesis.secret-key | Amazon AWS Secret Key | 字符串 |
所需的 Kinesis 组件选项
您必须在 registry 中提供 amazonKinesisClient,并配置了代理和相关凭证。