Is KafkaIO supported on Flink Runner? I see the code in Github, but it is not part of .4 libraries
> On Feb 2, 2017, at 8:54 AM, user-digest-h...@flink.apache.org wrote: > > > Have a look at > https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java > > <https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java>. > > >
