Bowen Li created FLINK-7367:
-------------------------------
Summary: Parameterize FlinkKinesisProducer on
RecordMaxBufferedTime, MaxConnections, RequestTimeout, and more
Key: FLINK-7367
URL: https://issues.apache.org/jira/browse/FLINK-7367
Project: Flink
Issue Type: Improvement
Components: Kinesis Connector
Affects Versions: 1.3.0
Reporter: Bowen Li
Assignee: Bowen Li
Fix For: 1.3.3
Right now, FlinkKinesisProducer only expose two configs for the underlying
KinesisProducer:
- AGGREGATION_MAX_COUNT
- COLLECTION_MAX_COUNT
Well, according to [AWS
doc|http://docs.aws.amazon.com/streams/latest/dev/kinesis-kpl-config.html] and
[their sample on
github|https://github.com/awslabs/amazon-kinesis-producer/blob/master/java/amazon-kinesis-producer-sample/default_config.properties],
developers can set more to make the max use of KinesisProducer, and make it
fault-tolerant (e.g. by increasing timeout).
We need to parameterize FlinkKinesisProducer in order to pass in params listed
in AWS doc and sample
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
