[jira] [Created] (FLINK-18661) [Kinesis][EFO] Stream consumer Registration/Deregistration

["Danny Cranmer (Jira)" <ji...@apache.org>]

Danny Cranmer created FLINK-18661:
-------------------------------------

             Summary: [Kinesis][EFO] Stream consumer Registration/Deregistration
                 Key: FLINK-18661
                 URL: https://issues.apache.org/jira/browse/FLINK-18661
             Project: Flink
          Issue Type: Sub-task
          Components: Connectors / Kinesis
            Reporter: Danny Cranmer
             Fix For: 1.12.0


*Background*
In order to utilise an EFO subscription a consumer must register and acquire a ConsumerARN. Subsequently the ConsumerARN can be used to request a subscription and start receiving data. 

*Scope*
- Implement stream registration and deregistration in the {{KinesisV2ProxyInterface}}
- Invoke registration based on the specified strategy:
-- {{LAZY}}: At start-up within {{KinesisDataFetcher}}
-- {{EAGER}}: Within {{FlinkKinesisConsumer}} constructor (add the consumer ARN to config)
-- {{NONE}}: Disabled
- Invoke deregistration based on the specified strategy:
-- {{LAZY|EAGER}}: During tear-down within {{KinesisDataFetcher}}
-- {{NONE}}: Disabled



--
This message was sent by Atlassian Jira
(v8.3.4#803005)