Multiple consumers on a subpartition

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Multiple consumers on a subpartition

albertjonathan
Hello,

Is there a way Flink allow a (pipelined) subpartition to be consumed by multiple consumers? If not, would it make more sense to implement it as multiple input channels for a single subpartition or multiple subpartition views for each input channel?

Any suggestion is appreciated.

Thanks