Hi, KafkaIO should be supported. Have you tried following the Quickstart and adding the right dependency for the KafkaIO?
Cheers, Aljoscha On Thu, 2 Feb 2017 at 16:32 Boris Lublinsky <boris.lublin...@lightbend.com> wrote: > 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 > . > > > >
