[ https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895758#comment-15895758 ]
ASF GitHub Bot commented on FLINK-4286: --------------------------------------- Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/3270 Hi @rmetzger, i delete example for Kafka v0.8 and left only for Kafka v0.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)