Re: user Digest 2 Feb 2017 14:54:03 -0000 Issue 1703

[Boris Lublinsky]

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, [hidden email] 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. 

[Aljoscha Krettek]

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 <[hidden email]> 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, [hidden email] 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.