Skip to main content Skip to complementary content

cAWSKinesis Standard properties

These properties are used to configure cAWSKinesis running in the Standard Job framework.

The Standard cAWSKinesis component belongs to the AWS and Connectivity families.

Basic settings

Connection

Select an AWS Kinesis connection component from the list to reuse the connection details you already defined.

Stream Name

Enter the name of the stream.

Camel AWS Kinesis Partition Key

This option is available only when cAWSKinesis is used as a Producer.

Specify which shard in the stream the data record is assigned to.

Iterator Type

This option is available only when cAWSKinesis is used as a Consumer.

Select where in the Kinesis stream to start getting records from:
  • AT_SEQUENCE_NUMBER: Start getting records from the position denoted by a specific sequence number. Enter the sequence number in the Sequence Number field.
  • AFTER_SEQUENCE_NUMBER: Start getting records right after the position denoted by a specific sequence number. Enter the sequence number in the Sequence Number field.
  • TRIM_HORIZON: Start getting records at the last untrimmed record in the shard, which is the oldest data record in the shard.
  • LATEST: Start getting records just after the most recent record in the shard, so that you always read the most recent data in the shard.
  • AT_TIMESTAMP: Start getting records from the position denoted by a specific time stamp. Enter the time stamp in the Timestamp field.

Usage

Usage rule

cAWSKinesis can be a start, middle or end component in a Route. It has to be used with the cAWSConnection component, which creates a connection to Amazon Web Services. For more information about cAWSConnection, see cAWSConnection.

Limitation

 n/a

Did this page help you?

If you find any issues with this page or its content – a typo, a missing step, or a technical error – please let us know!