Thomas Weise created FLINK-9926: ----------------------------------- Summary: Allow for ShardConsumer override in Kinesis consumer Key: FLINK-9926 URL: https://issues.apache.org/jira/browse/FLINK-9926 Project: Flink Issue Type: Task Components: Kinesis Connector Reporter: Thomas Weise Assignee: Thomas Weise
There are various reasons why the user may want to override the consumer. Examples are to optimize the fetch behavior or to add additional metrics or logging. Instead of baking the constructor into runFetcher, create a customizable factory method. -- This message was sent by Atlassian JIRA (v7.6.3#76005)