Create a Kinesis source that uses an Amazon Web Services connection to connect to Amazon Kinesis.
On the
Design
tab, click the
Sources
view.
From the
Actions
menu on the upper-right corner of the view, select
New
.
The
New Source
dialog box appears.
Enter a name for the Kinesis source, and select the type
Amazon Kinesis Source
.
Select the configured Amazon Web Services connection.
In the
Topic Information
section, select the configured topic for the Kinesis source.
In the
Configuration
section, configure the following parameters:
Enter a stream name to identify the stream that you want to read from Amazon Kinesis.
Select the
Latest
shard iterator type to read the most recent data in the shard.
Select the
String Message
message type.
Select JSON encoded message if you want to parse JSON messages and publish events with key-value pairs. Select custom encoding message type if you want RulePoint to process other message types. For custom encoding message type, you need a marshaler. The JSON encoded or string message type processes a single event at a time. You must create a marshaler and use the custom message encoding type to process multiple events at a time.
Retain the default values for the rest of the fields. For information about the description for each of the fields, the configurations for the Kinesis source and its associated objects, and marshaler details, see the