[FLINK-29205] FlinkKinesisConsumer not respecting Credential Provider configuration for EFO

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.2
• Fix Version/s: 1.16.0, 1.15.3
• Component/s: Connectors / Kinesis
• Labels: pull-request-available
• Assignee: Danny Cranmer
• Reporter: Danny Cranmer
• Created: 06/Sep/22 08:37
• Updated: 06/Sep/22 16:00
• Resolved: 06/Sep/22 16:00

Description

Reported in https://lists.apache.org/thread/xgpk0n59z5wq7kg6j8m8pgy5mcjzvvw5

 

FlinkKinesisConsumer is not respecting the credential provider configuration. It appears as though the legacy property transform is discarding valid config, this results in the AUTO credential provider being used

• https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2Factory.java#L65

Issue Links

• links to: GitHub Pull Request #20768
• links to: GitHub Pull Request #20769
• links to: GitHub Pull Request #20770