[
https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853965#comment-15853965
]
ASF GitHub Bot commented on FLINK-4286:
---------------------------------------
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 <dmitrii_knia...@epam.com>
Date: 2017-02-06T08:58:52Z
[FLINK-4286] Have Kafka examples that use the Kafka 0.9 connector
----
> Have Kafka examples that use the Kafka 0.9 connector
> ----------------------------------------------------
>
> Key: FLINK-4286
> URL: https://issues.apache.org/jira/browse/FLINK-4286
> Project: Flink
> Issue Type: Improvement
> Components: Examples
> Reporter: Tzu-Li (Gordon) Tai
> Assignee: Dmitrii Kniazev
> Priority: Minor
> Labels: starter
>
> The {{ReadFromKafka}} and {{WriteIntoKafka}} examples use the 0.8 connector,
> and the built example jar is named {{Kafka.jar}} under
> {{examples/streaming/}} in the distributed package.
> Since we have different connectors for different Kafka versions, it would be
> good to have examples for different versions, and package them as
> {{Kafka08.jar}} and {{Kafka09.jar}}.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
