package drivers
- Alphabetic
- Public
- All
Type Members
- class KinesisStreamingDataParser extends StreamingDataParser[Record]
Value Members
-
object
KinesisPipelineDriver
Provides a driver that listens to a kafka cluster and one or more topics.
Provides a driver that listens to a kafka cluster and one or more topics.
Required parameters:
"driverSetupClass" - This class will handle all of the initial setup such as building out pipelines, creating the PipelineContext. "streamName" - The Kinesis stream where data will be pulled "region" - A valid AWS region
Optional Parameters:
"appName" - The name of this app to use when check pointing Kinesis sequence numbers. "awsAccessKey" - The AWS access key used to connect "awsAccessSecret" - The AWS access secret used to connect "duration-type" - should be seconds or minutes "duration" - should be a number "terminationPeriod" - This is a number (ms) that informs the system to run for the specified amount of time and then shut down.