GitHub user aozturk opened a pull request:
https://github.com/apache/flink/pull/2016
[FLINK-3923] [connector-kinesis] Unify configuration conventions of tâ¦
This pull request includes the changes as clearly described in the issue.
[FLINK-3923] Unify configuration conventions of the Kinesis producer to the
same as the consumer
Currently, the Kinesis consumer and producer are configured differently.
The producer expects a list of arguments for the access key, secret,
region, stream. The consumer is accepting properties (similar to the Kafka
connector).
The objective of this issue is to change the producer so that it is also
using a properties-based configuration (including an input validation step)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aozturk/flink FLINK-3923
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2016.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2016
----
commit b3f253a016fb3fdd9ecfd1f03ff9313d3f977e3f
Author: Abdullah Ozturk <[email protected]>
Date: 2016-05-21T14:38:53Z
[FLINK-3923] [connector-kinesis] Unify configuration conventions of the
Kinesis producer to the same as the consumer
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
