Hello,
Can you please share views about below mail?
Rgds,
Kamal
From: Kamal Mittal via user
Sent: 28 July 2023 07:59 AM
To: Martijn Visser
Cc: user@flink.apache.org
Subject: RE: Custom TCP server socket source
Hello Martijn,
I followed the same link and created Enumerator
Socket connections (Socket object) as split (unbounded) in respective source
readers (task managers).
Please share your views.
[cid:image001.png@01D9C129.15A3B350]
Rgds,
Kamal
From: Martijn Visser
Sent: 27 July 2023 06:19 PM
To: Kamal Mittal
Cc: user@flink.apache.org
Subject: Re: Custom TCP server
Hi Kamal,
The best starting point would be to look at how to write a custom source
connector. Have a look at
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/sources/
which also includes links to the various classes that you'll need. Please
let us know what else you've
Hello,
I need to write "Custom server socket source" which accepts client connections
over a port.
1. How to scale it across task managers with parallelism <= no. of task
managers and with same single port
2. This is needed w.r.t Kubernetes POD deployment model where each POD is
