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
.
02.02.2017 1:07 AM "Boris Lublinsky"
napisał(a):
> I am trying to write a quick sample of streaming word count using Beam
> APIs and FlinkBeamRunner.
> The probl
I am trying to write a quick sample of streaming word count using Beam APIs and
FlinkBeamRunner.
The problem that I am getting into is that
apply("Write to Kafka", Write.to(UnboundedFlinkSink.of(kafkaSink)))
Does not work in this way - it assumes bounded stream and mine is unbounded.
I have not
