Hi Janani,
Have you implemented UDP source using the SourceFunction interface?
--
View this message in context:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/UDP-support-in-Streaming-API-tp4715p12182.html
Sent from the Apache Flink Mailing List archive. mailing list archive at
Dear Janani,
Apache Kafka as a source is supported by our system, check out the
documentation for details. [1]
You can use UDP as a source if you wish, just bear in mind the standard
disadvantages of it: the possibility of losing messages and that you will
have to manually deal with the serializa
Hi Stephan,
Yes, you are right. I will try writing a custom data source as you
mentioned. Also, I still need to check the possibility of our system to use
Apache Kafka as a broker. Could it be possible for you to point out here
the downsides of using UDP as a source for streaming data?
Thanks,
Ja
Hi Janani!
Do I understand you correctly in that you want a Flink stream source that
receives UDP datagrams and turns them into Flink DataStream?
Such a thing is not in there, yet. The interface to define custom data
sources is rather simple, though, it should be possible to add something
like th
