7.4. 组件选项

amazonKinesisClient (common)

Autowired Amazon Kinesis 客户端用于此端点的所有请求。

KinesisClient

cborEnabled (common)

此选项将在执行期间设置 CBOR_ENABLED 属性。

true

布尔值

configuration (common)

组件配置.

Kinesis2Configuration

overrideEndpoint (common)

设置覆盖端点的需要。这个选项需要与 uriEndpointOverride 选项结合使用。

false

布尔值

proxyHost (common)

在实例化 Kinesis 客户端时定义代理主机。

字符串

proxyPort (common)

在实例化 Kinesis 客户端时定义代理端口。

整数

proxyProtocol (common)

在实例化 Kinesis 客户端时定义代理协议。

Enum 值：

HTTPS

协议

region (common)

Kinesis Firehose 客户端需要工作的区域。使用此参数时，配置将预期区域（如 ap-east-1）的小写名称，您需要使用名称 Region.EU_WEST_1.id()。

字符串

trustAllCertificates (common)

如果要在覆盖端点时信任所有证书。

false

布尔值

uriEndpointOverride (common)

设置覆盖 uri 端点。这个选项需要与 overrideEndpoint 选项结合使用。

字符串

useDefaultCredentialsProvider (common)

设置 Kinesis 客户端是否应该希望通过默认凭证提供程序加载凭证，或者希望传递静态凭证。

false

布尔值

bridgeErrorHandler (consumer)

允许将消费者桥接到 Camel 路由错误处理程序，这意味着当消费者试图选择传入消息或类似信息时发生异常，现在将作为消息处理并由路由 Error Handler 处理。默认情况下，使用者将使用 org.apache.camel.spi.ExceptionHandler 来处理例外情况，该处理程序将被记录在 WARN 或 ERROR 级别，并忽略。

false

布尔值

iteratorType (consumer)

定义在 Kinesis 流中开始获取记录的位置。

Enum 值：

TRIM_HORIZON

ShardIteratorType

maxResultsPerRequest (consumer)

每次轮询中将获取的最大记录数。

1

int

resumeStrategy (consumer)

为 AWS Kinesis 定义恢复策略。如果提供，默认策略将读取 sequenceNumber。

KinesisUserConfigurationResumeStrategy

KinesisResumeStrategy

sequenceNumber (consumer)

开始轮询的序列号。如果 iteratorType 设置为 AFTER_SEQUENCE_NUMBER 或 AT_SEQUENCE_NUMBER，则需要此项。

字符串

shardClosed (consumer)

定义在分片关闭时的行为是什么。可能的值有 ignore, silent 和 fail。如果忽略了消息，并且消费者将从开始重新启动，如果为 silent，则消费者将从开始记录。如果开始，消费者将引发故障关闭状态异常。

Enum 值：

ignore

Kinesis2ShardClosedStrategyEnum

shardId (consumer)

定义 Kinesis 流中要从哪些分片 ID 获取记录。

字符串

lazyStartProducer (producer)

生成者是否应懒惰启动 （在第一个消息中）。通过懒惰启动，您可以使用此选项来允许 CamelContext 和路由在生成者启动期间启动，并导致路由启动失败。通过懒惰启动，启动失败可以在路由信息时通过 Camel 的路由错误处理程序进行处理。请注意，在处理第一个消息时，创建并启动生成者可能需要稍等时间，并延长处理的总处理时间。

false

布尔值

asyncClient (advanced)

如果我们希望 KinesisAsyncClient 实例设为 true。

false

布尔值

autowiredEnabled (advanced)

是否启用自动关闭。这用于自动关闭选项（选项必须标记为 autowired），方法是在 registry 中查找查找是否有单个匹配类型实例，然后在组件上配置。这可以用于自动配置 JDBC 数据源、JMS 连接工厂、AWS 客户端等。

true

布尔值

healthCheckConsumerEnabled (health)

用于启用或禁用此组件中的所有基于消费者的健康检查。

true

布尔值

healthCheckProducerEnabled (health)

用于启用或禁用此组件中的所有基于制作者的健康检查。注意： 默认情况下，Camel 已禁用所有基于制作者的健康检查。您可以通过设置 camel.health.producersEnabled=true 来全局打开制作者检查。

true

布尔值

accessKey (security)

Amazon AWS 访问密钥.

字符串

profileCredentialsName (security)

如果使用配置文件凭据提供程序，此参数将设置配置文件名称。

字符串

secretKey (security)

Amazon AWS Secret 密钥。

字符串

sessionToken (security)

当用户需要假定 IAM 角色时使用的 Amazon AWS Session Token。

字符串

trustAllCertificates (security)

如果要在覆盖端点时信任所有证书。

false

布尔值

useDefaultCredentialsProvider (security)

设置 Kinesis 客户端是否应该希望通过默认凭证提供程序加载凭证，或者希望传递静态凭证。

false

布尔值

useProfileCredentialsProvider (security)

设置 Kinesis 客户端是否应该预期通过配置集凭证供应商加载凭证。

false

布尔值

useSessionCredentials (security)

设置 Kinesis 客户端是否应该预期使用 Session 凭证。这在用户需要假设 IAM 角色在 Kinesis 中执行操作时非常有用。

false

布尔值