CustomLocalSourceSink Apache Flume, Reactive streams. General usage of Flume [ Source -> Channel -> Sink ] In this case. for any reasons [ Source -> Channel -> PubSink extends AbstractPubSink ] -> [ SubSource -> Channel -> Sink ]