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
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
Hi,
Does Flink's streaming api has support for
reading streams of data via Java UDP (DatagramSocket)? If so kindly
advise me in which release of Flink I can find it.
Thanks,
Janani
