[ https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894965#comment-15894965 ]
Robert Metzger commented on FLINK-4286: --------------------------------------- I would vote to not have two examples that basically differ only in the Kafka version. We can just generally update the Kafka 0.8-based example to Kafka 0.9 > 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)