Patent ID: 11962633
Assignee: INTERNATIONAL BUSINESS MACHINES CORPORATION
Field: Audio-visual technology (Electrical engineering)
Classification: CPC H | IPC H

Claim 0:
1. A computer-implemented method for downscaling a streaming platform in an event-driven microservice architecture, the method comprising:
upon a consumer being removed from a consumer group that has a greatest number of consumers among consumer groups in a distributed streaming platform, determining whether a number of partitions in a topic in the distributed streaming platform is greater than a number of consumers in the consumer group;
in response to determining that the number of the partitions is greater than the number of consumers in the consumer group, downscaling the distributed streaming platform, wherein a partition consumed by the removed consumer is to be removed from the topic;
stopping message publishing to the to-be-removed partition;
removing an assignment of the to-be-removed partition to the removed consumer;
assigning remaining messages in the to-be-removed partition to one or more remaining consumers in the consumer group and to one or more consumers in consumer groups other than the consumer group;
determining whether all the remaining messages are consumed by the one or more remaining consumers in the consumer group and by the one or more consumers in the consumer groups other than the consumer group;
in response to determining that all the remaining messages are consumed, deleting the to-be-removed partition from the topic.