You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/07/23 23:07:00 UTC
[jira] [Created] (FLINK-9926) Allow for ShardConsumer override in
Kinesis consumer
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)