[jira] [Created] (FLINK-18513) [Kinesis][EFO] Add AWS SDK v2.x dependency and FanOutKinesisProxy

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18513) [Kinesis][EFO] Add AWS SDK v2.x dependency and FanOutKinesisProxy

Shang Yuanchun (Jira)
Danny Cranmer created FLINK-18513:
-------------------------------------

             Summary: [Kinesis][EFO] Add AWS SDK v2.x dependency and FanOutKinesisProxy
                 Key: FLINK-18513
                 URL: https://issues.apache.org/jira/browse/FLINK-18513
             Project: Flink
          Issue Type: Sub-task
            Reporter: Danny Cranmer


*Background*

EFO requires the AWS SDK v2.x dependency. Version 1.x cannot be removed from the project as other component require it (DynamoDB streams and KPL), therefore we will use AWS SDK 1.x and 2.x side by side.

*Scope*

This change will introduce the new dependency and Kinesis V2 proxy:
 * Update pom file to include the new dependency
 ** Does it need to be shaded?
 * Add a {{KinesisProxyV2}} with the following methods:
 ** {{subscribeToShard}}
 ** {{registerStreamConsumer}}
 ** {{deregisterStreamConsumer}}



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