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)
