Upgrading components of a messaging system used by a microservice-based application

A computer-implemented method, comprising:

• generating, by a microservice of a plurality of microservices, a data object associated with a data object version;
• determining a topic associated with the data object, wherein the topic is one of a plurality of topics of a publish-subscribe messaging system;
• identifying, based on the determined topic, a mapping between the data object version and a message object version;
• updating statistics associated with the data object version to indicate that a message object encapsulating the data object version is being sent to a communication microservice;
• and
• sending the message object to the communication microservice.

A non-transitory machine-readable storage medium storing instructions which, when executed by a processor, cause performance of operations comprising:

• receiving, by a microservice of a plurality of microservices, a message object from a first communication microservice of a plurality of communication microservices, wherein the message object is associated with a first message object version, and wherein the first communication microservice supports the first message object version;
• in response to receiving the message object associated with the first message object version, identifying:
• a version mapping that maps the first message object version to a data object version;
• and
• a statistics entry indicating a number of message objects associated with the data object version currently in process by any of the plurality of microservices;
• determining, based on the statistics entry, that the number of message objects associated with the data object version currently in process is zero;
• and
• based on the determination that the number of message objects associated with the data object version currently in process is zero, updating the version mapping from the first message object version to a second message object version.

A non-transitory machine-readable storage medium storing instructions which, when executed by a processor, cause performance of operations comprising:

• generating, by a microservice of a plurality of microservices, a data object associated with a data object version;
• determining a topic associated with the data object, wherein the topic is one of a plurality of topics of a publish-subscribe messaging system;
• identifying, based on the determined topic, a mapping between the data object version and a message object version;
• updating statistics associated with the data object version to indicate that a message object encapsulating the data object version is being sent to a communication microservice;
• and
• sending the message object to the communication microservice.