Hello Community, I have a operator pipeline like as below, is it ok if "source" task opens threads by using java thread pool and parallelize the work?
This is needed for accepting multiple client socket connections in "single custom source server socket function". Single Custom source server socket function - ServerSocket serversocket = new ServerSocket(9999); Now using thread pool accept multiple connections in separate threads = new Runnable () -> serversocket.accept(); [cid:image001.png@01D9C51A.0C833FD0] Rgds, Kamal
