You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/07/07 07:53:00 UTC
[jira] [Updated] (FLINK-18513) [Kinesis][EFO] Add AWS SDK v2.x
dependency and FanOutKinesisProxy
[ https://issues.apache.org/jira/browse/FLINK-18513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Danny Cranmer updated FLINK-18513:
----------------------------------
Description:
*Background*
EFO requires the AWS SDK v2.x dependency. Version 1.x cannot be removed from the project as other modules 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}}
was:
*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}}
> [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
> Priority: Major
>
> *Background*
> EFO requires the AWS SDK v2.x dependency. Version 1.x cannot be removed from the project as other modules 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)