3.3. 组件选项


AWS Kinesis 组件支持 22 选项,如下所示。

Name描述默认类型

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 客户端时定义代理协议。

枚举值:

  • HTTP
  • HTTPS

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,这意味着在消费者尝试获取传入的消息时发生任何异常,或像这样一样处理,消息现在将被作为消息进行处理,并由路由 Error Handler 处理。默认情况下,使用者将使用 org.apache.camel.spi.ExceptionHandler 处理异常,该处理程序将记录在 WARN 或 ERROR 级别并忽略。

false

布尔值

iteratorType (consumer)

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

枚举值:

  • AT_SEQUENCE_NUMBER
  • AFTER_SEQUENCE_NUMBER
  • TRIM_HORIZON
  • LATEST
  • AT_TIMESTAMP
  • null

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。如果忽略消息将被记录,并且消费者从一开始就重新启动,如果没有记录,消费者将从一开始就开始,当出现失败 ReachedClosedStateException 时,将引发 ReachedClosedStateException。

枚举值:

  • Ignore
  • fail
  • silent

Ignore

Kinesis2ShardClosedStrategyEnum

shardId (consumer)

定义 Kinesis 流中的哪个 shardId 从中获取记录。

 

字符串

lazyStartProducer (producer)

制作者是否应该启动 lazy(在第一个消息上)。通过启动 lazy,您可以使用它来允许 CamelContext 和路由在启动期间启动,否则在启动期间出现问题,并导致路由启动失败。通过将这个启动延迟到 lazy 后,可以在通过 Camel 的路由错误处理程序路由消息期间处理启动失败。注意在处理第一个消息时,创建并启动制作者可能花费较少的时间,从而延长处理的总处理时间。

false

布尔值

autowiredEnabled (advanced)

是否启用自动。这用于自动自动自动选项(选项必须标记为 autowired),方法是在 registry 中查找是否有匹配的类型实例,然后在组件上进行配置。这可用于自动配置 JDBC 数据源、JMS 连接工厂、AWS 客户端等。

true

布尔值

accesskey (安全性)

Amazon AWS 访问密钥.

 

字符串

secretKey (security)

Amazon AWS Secret 密钥。

 

字符串

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.