System and method to support in-order message processing with reactive microservices

A system comprising:

• a processor;
• a data bus coupled to the processor;
• and
• a non-transitory, computer-readable storage medium embodying computer program code, the non-transitory, computer-readable storage medium being coupled to the data bus, the computer program code interacting with a plurality of computer operations for processing in-order messages executable by the processor and configured for:
• performing in-order messaging within a message broker with unique message keys that ensure each batch of messages are sent on the same message broker partition;
• providing through a reactive generic data streaming processor, parallel data stream uniquely grouped to each message broker partition by implementing coding precautions through concatMap to maintain the parallel data stream, wherein order is preserved through a key that includes SystemID and data objectType;
• maintaining in-order processing on each parallel data stream by using downstream publishers that preserve strict order in each data stream;
• and
• providing a terminal sync message with a unique message key to identify end of in-order streaming a message group.

A non-transitory, computer-readable storage medium embodying computer program code for processing in-order messages, the computer program code comprising computer executable instructions configured for:

• performing in-order messaging a within a message broker with unique message keys that ensure each batch of messages are sent on the same message broker partition;
• providing through a reactive generic data streaming processor, parallel data stream uniquely grouped to each message broker partition by implementing coding precautions through concatMap to maintain the parallel data stream, wherein order is preserved through a key that includes SystemID and data objectType;
• maintaining in-order processing on each parallel data stream by using downstream publishers that preserve strict order in each data stream;
• and
• providing a terminal sync message with a unique message key to identify end of in-order streaming a message group.