Replace (at least try to avoid) ReplayProcessor and other deprecated classes (deprecated after upgrading to newer reactor version).

E.g. with Sinks.many().replay() ... (cannot be used yet - as we currently use 3.3.0, see next comment)