27.5. 使用方法

27.5.1. 由 Kinesis consumer 设置的消息标头
复制链接

Expand

标头	类型	描述
`CamelAwsKinesisSequenceNumber`	`字符串`	记录的序列号。这表示为一个字符串，因为它的大小不是由 API 定义。如果要将它用作数字类型，则使用
`CamelAwsKinesisApproximateArrivalTimestamp`	`字符串`	为记录的 arrival 时间分配的时间 AWS。
`CamelAwsKinesisPartitionKey`	`字符串`	标识数据记录的流中分配给的分片。

27.5.2. AmazonKinesis 配置
复制链接

您需要创建一个 AmazonKinesisClient 实例，并将其绑定到 registry

ClientConfiguration clientConfiguration = new ClientConfiguration();
clientConfiguration.setProxyHost("http://myProxyHost");
clientConfiguration.setProxyPort(8080);

Region region = Region.getRegion(Regions.fromName(region));
region.createClient(AmazonKinesisClient.class, null, clientConfiguration);
// the 'null' here is the AWSCredentialsProvider which defaults to an instance of DefaultAWSCredentialsProviderChain

registry.bind("kinesisClient", client);

ClientConfiguration clientConfiguration = new ClientConfiguration();
clientConfiguration.setProxyHost("http://myProxyHost");
clientConfiguration.setProxyPort(8080);

Region region = Region.getRegion(Regions.fromName(region));
region.createClient(AmazonKinesisClient.class, null, clientConfiguration);
// the 'null' here is the AWSCredentialsProvider which defaults to an instance of DefaultAWSCredentialsProviderChain

registry.bind("kinesisClient", client);

Copy to Clipboard

Toggle word wrap

然后，您必须在 amazonKinesisClient URI 选项中引用 AmazonKinesisClient。

from("aws-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient")
  .to("log:out?showAll=true");

from("aws-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient")
  .to("log:out?showAll=true");

Copy to Clipboard

Toggle word wrap

27.5.3. 提供 AWS 凭证
复制链接

建议使用 DefaultAWSCredentialsProviderChain 获取凭证，这是创建新 ClientConfiguration 实例时的默认设置，但在调用 createClient (…)时可以指定不同的 AWSCredentialsProvider。

27.5.4. Kinesis producer 用来写入 Kinesis 的消息标头。生产者希望消息正文是 byte[]。
复制链接

Expand

标头	类型	描述
`CamelAwsKinesisPartitionKey`	`字符串`	要传递给 Kinesis 来存储此记录的 PartitionKey。
`CamelAwsKinesisSequenceNumber`	`字符串`	可选参数以指示此记录的序列号。

27.5.5. 在记录成功存储时由 Kinesis producer 设置的消息标头
复制链接

Expand

标头	类型	描述
`CamelAwsKinesisSequenceNumber`	`字符串`	记录的序列号，如 Response Syntax中定义的
`CamelAwsKinesisShardId`	`字符串`	存储记录的分片 ID

返回顶部

27.5. 使用方法

27.5.1. 由 Kinesis consumer 设置的消息标头
复制链接

27.5.2. AmazonKinesis 配置
复制链接

27.5.3. 提供 AWS 凭证
复制链接

27.5.4. Kinesis producer 用来写入 Kinesis 的消息标头。生产者希望消息正文是 byte[]。
复制链接

27.5.5. 在记录成功存储时由 Kinesis producer 设置的消息标头
复制链接

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

27.5. 使用方法

27.5.1. 由 Kinesis consumer 设置的消息标头复制链接链接已复制到粘贴板!

27.5.2. AmazonKinesis 配置复制链接链接已复制到粘贴板!

27.5.3. 提供 AWS 凭证复制链接链接已复制到粘贴板!

27.5.4. Kinesis producer 用来写入 Kinesis 的消息标头。生产者希望消息正文是 byte[]。复制链接链接已复制到粘贴板!

27.5.5. 在记录成功存储时由 Kinesis producer 设置的消息标头复制链接链接已复制到粘贴板!

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

27.5.1. 由 Kinesis consumer 设置的消息标头
复制链接

27.5.2. AmazonKinesis 配置
复制链接

27.5.3. 提供 AWS 凭证
复制链接

27.5.4. Kinesis producer 用来写入 Kinesis 的消息标头。生产者希望消息正文是 byte[]。
复制链接

27.5.5. 在记录成功存储时由 Kinesis producer 设置的消息标头
复制链接