28.4. 사용법

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("kinesisFirehoseClient", client);

그런 다음 amazonKinesisFire followingClient URI 옵션에서 AmazonKinesisFirehoseClient 를 참조해야 합니다.

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

새 ClientConfiguration 인스턴스를 생성할 때 기본값인 DefaultAWSCredentialsProvider Cryostat를 사용하여 인증 정보를 가져오는 것이 좋지만 createClient(…​)를 호출할 때 다른 AWSCredentialsProvider 를 지정할 수 있습니다.