GitHub user gaborhermann opened a pull request:
https://github.com/apache/flink/pull/589
[FLINK-1753] Added Kafka connectors test and configuration options
* Added broker failure test to KafkaITCase, PersistentKafkaSource and
KafkaSink can now recover on broker failure.
* Added Properties parameter to KafkaSink constructor, thus custom Kafka
Producer configuration can be used
* Updated documentation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/gaborhermann/flink flink-1753
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/589.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 #589
----
commit 269e3fed810cb51dc22002570fae342f95503a9b
Author: Gábor Hermann <reckone...@gmail.com>
Date: 2015-03-23T13:18:55Z
[FLINK-1753] [streaming] Added Kafka broker failure test
commit a7732acf144d42f3c53c0917a45bf0096e463723
Author: Gábor Hermann <reckone...@gmail.com>
Date: 2015-04-13T09:19:08Z
[streaming] Added user-definable producer config to KafkaSink
commit dd1c3191d6337ff59fb04afab9e4337b9268377b
Author: Gábor Hermann <reckone...@gmail.com>
Date: 2015-04-13T09:37:47Z
[streaming] Updated Kafka connectors documentation
----
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
