GitHub user mylog00 opened a pull request:
https://github.com/apache/flink/pull/3270
[FLINK-4286] Have Kafka examples that use the Kafka 0.9 connector
There were added examples of using connector for Kafka v0.9. Examples using
0.8 connector renamed to "ReadFromKafka08" and "WriteIntoKafka08" respectively.
The pom.xml was modified: added config for separated packages Kafka08.jar and
Kafka09.jar using "maven-jar-plugin" instead "maven-shade-plugin".
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mylog00/flink FLINK-4286
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3270.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 #3270
----
commit fc3498f5db15c4a5685af8dc96728de07f852287
Author: Dmitrii Kniazev <[email protected]>
Date: 2017-02-06T08:58:52Z
[FLINK-4286] Have Kafka examples that use the Kafka 0.9 connector
----
---
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.
---
