You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2023/02/16 17:06:00 UTC
[jira] [Created] (FLINK-31108) Use StreamARN for API calls in Kinesis Connector
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)