osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[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)