Danny Cranmer created FLINK-34339: ------------------------------------- Summary: Add connector abstraction layer to remove reliance on AWWS SDK classes Key: FLINK-34339 URL: https://issues.apache.org/jira/browse/FLINK-34339 Project: Flink Issue Type: Sub-task Reporter: Danny Cranmer
In order to shim DDB streams we need to be able to support the Stream/Shard/Record etc concepts without tying to a specific implementation. This will allow us to mimic the KDS/DDB streams support in the old connector by providing a shim at the AWS SDK client. # Model {{software.amazon.awssdk.services.kinesis}} classes as native concepts # Push down any usage of {{software.amazon.awssdk.services.kinesis}} to a KDS specific class # Ensure that the bulk of the connector logic is reusable, the top level class would be implementation specific and shim in the write client factories and configuration -- This message was sent by Atlassian Jira (v8.20.10#820010)