Thanks for your answers, this makes the implementation way easier, I don't have to worry about queues.
I will take a look at the kafka connector. So my only remaining question is how serial stream sources are handled. If I have four independent streams, will the sources be handled by different parallel instances? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Data-ingestion-using-a-Flink-TCP-Server-tp7134p7164.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
