| CPC H04L 51/06 (2013.01) [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:
receiving a connection request sent from a first application instance of an application to a message broker, the connection request including, for a topic of the message broker, a consumer group identification and a consumer group version number, the consumer group identification identifying a group of message consumers and the consumer group version number indicating a version of the group of message consumers, the consumer group version number being different than a version number assigned to an application to which the group of message consumers is associated, each message consumer of the group of message consumers being microservices;
determining whether the consumer group version number is greater than a last known consumer group version number for the consumer group;
in response to a determination that the consumer group version number is greater than the last known consumer group version number for the consumer group, causing the message broker to disconnect one or more message consumers, including a second application instance of the application, having an older consumer group version number than the consumer group version number of the first application instance; and
causing assignment of one or more message consumers in a consumer group associated with the consumer group identification to one or more partitions of the topic, each partition responsible for serving a different subset of messages posted to the topic, each partition only assigned to a single message consumer at a time, such that messages posted to the topic are served by the message broker to one or more of the one or more message consumers associated with the consumer group identification.
|