| CPC H04L 51/56 (2022.05) [G06F 8/71 (2013.01)] | 20 Claims |

|
1. A system comprising:
at least one hardware processor; and
a computer-readable medium storing instructions that, when executed by the at least one hardware processor, cause the at least one hardware processor to perform operations comprising:
launching a consumer daemon on a computer server, the consumer daemon forwarding messages, posted to a first topic on a message broker, for a first set of one or more tenants to a first version of a microservice application for processing and forwarding messages posted, to the first topic, for a second set of one or more tenants to a second version of the microservice application for processing;
in response to receiving an indication that a first tenant in the first set has been reassigned to the second set:
identifying a first offset at which the first version of the microservice application ceased processing messages for the first tenant, an offset being a position among messages within a first partition of the first topic;
identifying a second offset at which the second version began processing messages for the first tenant;
comparing the first offset and the second offset; and
in response to a determination that the first offset is less than the second offset, performing a rewind operation including causing the second version of the microservice application to process messages posted to the first partition of the first topic for the first tenant between the first offset and the second offset.
|