27.5. 사용법
27.5.1. Cryostat 소비자가 설정한 메시지 헤더
| 헤더 | 유형 | 설명 |
|---|---|---|
|
|
| 레코드의 시퀀스 번호입니다. 이 값은 API에서 크기가 정의되지 않으므로 String으로 표시됩니다. 숫자 유형으로 사용해야 하는 경우 |
|
|
| AWS가 기록 도착 시간으로 할당된 시간입니다. |
|
|
| 데이터 레코드가 할당되는 스트림에서 shard를 식별합니다. |
27.5.2. AmazonKinesis 구성
AmazonKinesisClient의 인스턴스를 생성하여 레지스트리에 바인딩해야 합니다.
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 인증 정보 제공
새 ClientConfiguration 인스턴스를 생성할 때 기본값인 DefaultAWSCredentialsProvider Cryostat를 사용하여 인증 정보를 가져오는 것이 좋지만 createClient(…)를 호출할 때 다른 AWSCredentialsProvider 를 지정할 수 있습니다.
27.5.4. Cryostat 생산자가 Cryostat에 쓰기 위해 사용하는 메시지 헤더입니다. 생산자는 메시지 본문이 byte[] 임을 예상합니다.
| 헤더 | 유형 | 설명 |
|---|---|---|
|
|
| 이 레코드를 저장하기 위해 Cryostat에 전달할 PartitionKey입니다. |
|
|
| 이 레코드의 시퀀스 번호를 나타내는 선택적 매개 변수입니다. |
27.5.5. Record의 성공적인 스토리지에 대한 Cryostat 생산자가 설정한 메시지 헤더
| 헤더 | 유형 | 설명 |
|---|---|---|
|
|
| 응답구문에 정의된 레코드 시퀀스 번호 |
|
|
| 레코드가 저장된 shard ID |
