[ https://issues.apache.org/jira/browse/FLINK-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369773#comment-14369773 ]
ASF GitHub Bot commented on FLINK-1752: --------------------------------------- Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26778761 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/pom.xml --- @@ -46,9 +53,13 @@ under the License. <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> - <version>0.8.2.0</version> + <version>${kafka.version}</version> <exclusions> --- End diff -- If this is only about the different names of `leader.getConnectionString()`, we can also play some reflection tricks. > Add test to Kafka streaming connector > ------------------------------------- > > Key: FLINK-1752 > URL: https://issues.apache.org/jira/browse/FLINK-1752 > Project: Flink > Issue Type: Improvement > Affects Versions: 0.9 > Reporter: Robert Metzger > Assignee: Robert Metzger > > Add a test for Flink Streaming's Kafka connector using an integrated Kafka > and Zookeeper server. -- This message was sent by Atlassian JIRA (v6.3.4#6332)