Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Post Processing XSL configuration can be used to transform the response message before sending it to the output port.

...

Click the AWS Connection Details ellipsis  button to configure the properties.


Figure 2: KinesisConsumer connection configuration properties

Access key 

Specify the Access Key id

...

Used to specify the position in the stream where a new application should start from.


Figure 3: Initial Position In Stream property options

  • LATEST: Fetches you always read the most recent data in the shard
  • TRIM_HORIZON: Gets the record of last untrimmed record in the shard in the system (the oldest data record in the shard)

...

Specify the required output type. Data is interpreted as UTF-8 characters if string is selected.


Figure 4: Payload Data Type property options

  • String
  • Bytes

Check Point Interval (ms)

...

Click the Threadpool Configuration ellipsis button to configure the Threadpool Configuration properties. 


Figure 5: KinesisConsumer Threadpool configuration properties

Enable Thread Pool

Enable this option to configure the properties that appear as below.

...

The following flow demonstrates a flow of Kinesis Consumer, which fetches the data from the provided StreamName.


Figure 6: KinesisConsumer sample flow

Output Message

The output message consists of following elements

...

Approximate time stamp of the record after retrieving from the kinesis stream.

Image Modified
Figure 7: Output displayed in the Display window

Adaptavist ThemeBuilder EngineAtlassian Confluence