You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Boris Lublinsky <bo...@lightbend.com> on 2017/02/02 15:32:50 UTC

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

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-help@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>. 
> 
>

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

Posted by Aljoscha Krettek <al...@apache.org>.

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 <bo...@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-help@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
> .
>
>
>
>