Reading Data from an Amazon Kinesis Stream

Procedure

To read data from your Kinesis stream, add a tKinesisInput component and connect the tRowGenerator component to it with an InParallel trigger.
In the Basic settings view of the tKinesisInput component, provide your Amazon credentials.
Provide your Kinesis Stream name and the corresponding Endpoint url.
Select the Explicitly set authentication parameters option and enter your Region, as mentioned in AWS Regions and Endpoints.
Add a tReplicate component and connect it with tKinesisInput.

The purpose of the tReplicate component is to have a processing component in the Job; otherwise, the execution of the Job will fail. The tReplicate component allows the Job to compile without modifying the data.
Add a tExtracDelimitedFields component and connect it to the tReplicate component.

The tExtractDelimitedFields will extract the data from the serialized message generated by the tKinesisInput component.
Add a tLogRow component to display the output on the console and on its Basic settings view select Table (print values in cells of a table) to display the data in a table.

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