27.5. 使用方法
27.5.1. 由 Kinesis consumer 设置的消息标头
| 标头 | 类型 | 描述 |
|---|---|---|
|
|
| 记录的序列号。这表示为一个字符串，因为它的大小不是由 API 定义。如果要将它用作数字类型，则使用 |
|
|
| 为记录的 arrival 时间分配的时间 AWS。 |
|
|
| 标识数据记录的流中分配给的分片。 |
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);
然后，您必须在 amazonKinesisClient URI 选项中引用 AmazonKinesisClient。
from("aws-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient")
.to("log:out?showAll=true");27.5.3. 提供 AWS 凭证
建议使用 DefaultAWSCredentialsProviderChain 获取凭证，这是创建新 ClientConfiguration 实例时的默认设置，但在调用 createClient (…)时可以指定不同的 AWSCredentialsProvider。
27.5.4. Kinesis producer 用来写入 Kinesis 的消息标头。生产者希望消息正文是 byte[]。
| 标头 | 类型 | 描述 |
|---|---|---|
|
|
| 要传递给 Kinesis 来存储此记录的 PartitionKey。 |
|
|
| 可选参数以指示此记录的序列号。 |
27.5.5. 在记录成功存储时由 Kinesis producer 设置的消息标头
| 标头 | 类型 | 描述 |
|---|---|---|
|
|
| 记录的序列号，如 Response Syntax中定义的 |
|
|
| 存储记录的分片 ID |
