[FLINK-9926] Allow for ShardConsumer override in Kinesis consumer

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.6.0
• Component/s: Connectors / Kinesis
• Labels: pull-request-available
• Assignee: Thomas Weise
• Reporter: Thomas Weise
• Created: 23/Jul/18 23:06
• Updated: 27/Apr/21 18:07
• Resolved: 01/Aug/18 13:30

Description

There are various reasons why the user may want to override the consumer. Examples are to optimize the run loop or to add additional metrics or logging. Instead of baking the constructor into runFetcher, create a customizable factory method.

 

Issue Links

• is related to: FLINK-4582 Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams
• links to: GitHub Pull Request #6427