Hong Liang Teoh created FLINK-31108: ---------------------------------------
Summary: Use StreamARN for API calls in Kinesis Connector Key: FLINK-31108 URL: https://issues.apache.org/jira/browse/FLINK-31108 Project: Flink Issue Type: Improvement Components: Connectors / Kinesis Affects Versions: 1.16.1, 1.15.3 Reporter: Hong Liang Teoh Fix For: 1.17.1 Currently, the FlinkKinesisConsumer (Polling + EFO) + FlinkKinesisProducer uses the stream name during API calls We want to change this to the StreamARN. There are two reasons for this: - This allows lower latency calls to the Kinesis endpoint for GetRecords API - Paves the way for allowing user target cross-account streams without assume role (i.e. IAM role in account A but target stream in account B) The APIs that are currently called: * ** ListShards ** GetShardIterator ** GetRecords ** DescribeStream ** DescribeStreamSummary ** DescribeStreamConsumer (already uses StreamARN) ** RegisterStreamConsumer (already uses StreamARN) -- This message was sent by Atlassian Jira (v8.20.10#820010)