Name of the source. The source name must be unique.

Optional. The description of the service.

Type of source. Select

Amazon Kinesis Source

.

The connection type with which you want to associate the source. Select

Amazon Web Services Connection

. You must create the connection before you create an Amazon Kinesis source.

The topic to which the properties of a Kinesis stream are mapped. Select the topic name that corresponds to the source.

The URL that identifies a host and a port that constitute as the entry point for a web service. Every web service request contains an end point. Some AWS products provide regional end points to make your requests. The regional end points reduce data latency in your application and facilitate faster connectivity.

The name to identify the stream that you want to capture and read records from Amazon Kinesis. The stream name must not exceed 128 characters and must not contain spaces. The stream name is added to the AWS account used by the application that creates the stream. Provide the number of shards you want to read from the stream in the Amazon Kinesis console. The average shard size of the data record to read from the stream must not exceed 50 KB.

A unique name for your Amazon Kinesis application, which is scoped to the AWS account and region used by the application. The application name must follow the regular expression pattern. The Kinesis Client Library (KCL) uses the application name to associate all the workers together on the same stream, and to create an Amazon DynamoDB table that maintains the state information for the application.

Specifies the position in the shard from which you want to start reading data records sequentially. You can select the following shard iterator types:

AT_SEQUENCE_NUMBER
. Reads data records from the position denoted by a specific sequence number.
AFTER_SEQUENCE_NUMBER
. Reads data right after the position denoted by a specific sequence number.
TRIM_HORIZON
. Reads data from the last untrimmed record in the shard in the system. The data read is the oldest data record in the shard.
LATEST
. Reads data after the most recent record in the shard.

A unique sequence number assigned by the Amazon Kinesis service when a record is put into the Amazon Kinesis stream. The shard iterator uses the sequence number to specify the position of the data record in the shard from where you want to start reading data records sequentially.

The message type of the data record. You can choose the following data record types:

JSON Encoded String Message
. Receive the message as a JSON encoded string and convert it as topic properties.
String Message
. Receive the message as a UTF-8 encoded string and send it to a topic property.
Custom Encoding
. Use the marshaller to decode the message and then convert it to topic properties.

Class name of the marshaller. The marshaller class is responsible for converting or enriching the source event properties. It must include the full class name including the classpath. You must add the jar file that contains this class into the RulePoint library.

Properties of the marshaller. You must pass the properties as comma-separated key-value pairs to the marshaller class. For example, property1=value1,property2=value2.