Reading Data from an Amazon Kinesis Stream
-
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.
Document get from Talend https://help.talend.com
Thank you for watching.
Subscribe
Login
0 Comments