Hi, To the best of my knowledge the following pattern should work just fine:
DataStream myStream = env.addSource(…).foo().bar() // for custom source, but any ; myStream.addSink(sink1); myStream.addSink(sink2); myStream.addSink(sink3); All of the records from `myStream` would be passed to each of the sinks. Piotrek > On 24 May 2020, at 19:34, Prasanna kumar <prasannakumarram...@gmail.com> > wrote: > > Hi, > > There is a single source of events for me in my system. > > I need to process and send the events to multiple destination/sink at the > same time.[ kafka topic, s3, kinesis and POST to HTTP endpoint ] > > I am able send to one sink. > > By adding more sink stream to the source stream could we achieve it . Are > there any shortcomings. > > Please let me know if any one here has successfully implemented one . > > Thanks, > Prasanna.
