flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Boris Lublinsky <boris.lublin...@lightbend.com>
Subject Re: user Digest 2 Feb 2017 14:54:03 -0000 Issue 1703
Date Thu, 02 Feb 2017 15:32:50 GMT
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>.

> 
> 


Mime
View raw message