Hello Hai,
Yes, we are working on a use case for Python/Flink that should go to
production soon. It's using the Flink runner in *streaming* mode. The
source is Kinesis, but we implemented support for Kafka also. You can find
that in our Beam fork [1]
The Flink runner supports multiple element
Hi Thomas,
This is Hai who works on portable runner for Samza. I have a few minor
question that I would like to get clarification on from you.
We chatted briefly at last beam meetup and you mention your flink portable
runner (Python) is going into production. So today are you using Beam
Python
