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 tried already and what issues you've encountered.
Best regards, Martijn On Thu, Jul 27, 2023 at 6:54 AM Kamal Mittal via user <user@flink.apache.org> wrote: > 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 running a task manager > > > > Doing it with in same task manager causes port collision which is expected. > > > > Rgds, > > Kamal >
