[jira] [Created] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration

Shang Yuanchun (Jira)
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)