3.6. 使用方法
3.6.1. 静态凭证和默认凭证提供程序
您可以通过指定 useDefaultCredentialsProvider 选项并将其设置为 true 来避免使用显式静态凭证。
- Java system properties - aws.accessKeyId and aws.secretKey
- 环境变量 - AWS_ACCESS_KEY_ID 和 AWS_SECRET_ACCESS_KEY。
- AWS STS 的 Web Identity Token。
- 共享凭证和配置文件。
- Amazon ECS 容器凭证 - 如果设置了环境变量 AWS_CONTAINER_CREDENTIALS_RELATIVE_URI,则从 Amazon ECS 加载。
- Amazon EC2 实例配置集凭据。
有关此信息的更多信息,您可以查看 AWS 凭证文档
3.6.2. 由 Kinesis consumer 设置的消息标头
| 标头 | 类型 | 描述 | 
|---|---|---|
| 
									 | 
									 | 记录的序列号。这表示为一个字符串,因为它的大小不是由 API 定义。如果要将它用作数字类型,则使用 | 
| 
									 | 
									 | 为记录的 arrival 时间分配的时间 AWS。 | 
| 
									 | 
									 | 标识数据记录的流中分配给的分片。 | 
3.6.3. AmazonKinesis 配置
					然后,您必须在 amazonKinesisClient URI 选项中引用 KinesisClientClient。
				
from("aws2-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient")
  .to("log:out?showAll=true");
from("aws2-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient")
  .to("log:out?showAll=true");3.6.4. 提供 AWS 凭证
建议您使用 DefaultAWSCredentialsProviderChain 获取凭证,这是创建新 ClientConfiguration 实例时的默认设置,但在调用 createClient (…)时可以指定不同的 AWSCredentialsProvider。
| 标头 | 类型 | 描述 | 
|---|---|---|
| 
									 | 
									 | 要传递给 Kinesis 来存储此记录的 PartitionKey。 | 
| 
									 | 
									 | 可选参数以指示此记录的序列号。 | 
3.6.6. 在记录成功存储时由 Kinesis producer 设置的消息标头
| 标头 | 类型 | 描述 | 
|---|---|---|
| 
									 | 
									 | 记录的序列号,如 Response Syntax中定义的 | 
| 
									 | 
									 | 存储记录的分片 ID |