flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration
Date Fri, 27 May 2016 21:10:14 GMT
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)

Mime
View raw message