I'm working on two different feeds for the same object (flight) and unable to find the correct processor or flow for the same. my requirement is to publish all two in single stream service. all feeds holds different information about the flights event and all are asynchronies and input driven by their own inputs. First feed gives me flight position, and second feed is about flight info. the catch is first feed (position) stop sending the messages once the flight is in stand, but other feed is continuously sending the messages. it would be great help if you can suggest the best approach to achieve this. I thought of using Field mapper (which can join two definitions) but problem is both are asynchronous and driven by their own inputs.