Distributed Messaging System and Method for Dynamic Partitioning in Distributed Messaging System

摘要

The present invention discloses a distributed message system and a dynamic partitioning method in a distributed message system. A dynamic partitioning method in a distributed message system according to an embodiment of the present invention includes determining whether a consumer without a partition assigned among a plurality of consumers exists; Equally dividing the messages remaining in the first partition in half among the plurality of partitions, and creating two new partitions to store the evenly divided messages in the two new partitions; Allocating the two new partitions to a consumer without the assigned partition and to a consumer that has been assigned to the first partition; And updating the metadata including list information about partitions and mapping information between each consumer and a partition allocated to each consumer; It may include.