Robert Metzger created FLINK-3983:
-------------------------------------
Summary: Allow users to set any (relevant) configuration parameter
of the KinesisProducerConfiguration
Key: FLINK-3983
URL: https://issues.apache.org/jira/browse/FLINK-3983
Project: Flink
Issue Type: Sub-task
Components: Kinesis Connector
Affects Versions: 1.1.0
Reporter: Robert Metzger
Currently, users can only set some of the configuration parameters in the
{{KinesisProducerConfiguration}} through Properties.
It would be good to introduce configuration keys for these keys so that users
can change the producer configuration.
I think these and most of the other variables in the
KinesisProducerConfiguration should be exposed via properties:
- aggregationEnabled
- collectionMaxCount
- collectionMaxSize
- connectTimeout
- credentialsRefreshDelay
- failIfThrottled
- logLevel
- metricsGranularity
- metricsLevel
- metricsNamespace
- metricsUploadDelay
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
