THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The Kinesis component supports receiving messages from and sending messages to Amazon Kinesis service.
| Info | ||
|---|---|---|
| ||
You must have a valid Amazon Web Services developer account, and be signed up to use Amazon Kinesis. More information are available at AWS Kinesis |
...
Name | Default Value | Context | Description |
|---|---|---|---|
amazonKinesisClient |
| Consumer | Reference to a |
maxMessagesPerPoll |
| Consumer | Maximum results that will be returned in each poll to the AWS API, Given that the shard iterator is unique to the consumer, changing it shouldn't effect other consumers. |
iteratorType |
| Consumer | One of trim_horizon or latestTRIM_HORIZON, LATEST, AFTER_SEQUENCE_NUMBER or AT_SEQUENCE_NUMBER. See http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html for descriptions of these two iterator types. |
| sequenceNumber | null | Consumer | The sequence number to start polling from. Required if iteratorType is set to AFTER_SEQUENCE_NUMBER or AT_SEQUENCE_NUMBER |
| Info | ||
|---|---|---|
| ||
You have to provide the amazonKinesisClient in the Registry with proxies and relevant credentials configured. |
...
You will need to create an instance of AmazonDynamoDBStreamsClient and AmazonKinesisClient and bind it to the registry
| Code Block | ||
|---|---|---|
| ||
ClientConfiguration clientConfiguration = new ClientConfiguration();
clientConfiguration.setProxyHost("http://myProxyHost");
clientConfiguration.setProxyPort(8080);
Region region = Region.getRegion(Regions.fromName(region));
region.createClient(AmazonDynamoDBStreamsClientAmazonKinesisClient.class, null, clientConfiguration);
// the 'null' here is the AWSCredentialsProvider which defaults to an instance of DefaultAWSCredentialsProviderChain
registry.bind("kinesisClient", client);
|
You then have to reference the AmazonKinesisClient in the amazonKinesisClient URI option.
| Code Block | ||
|---|---|---|
| ||
from("aws-kinesis://mykinesisstream?amazonKinesisClient=#kinesisClient") .to("log:out?showAll=true"); |
Providing AWS Credentials
...