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

摘要

Disclosed in the present invention are a distributed messaging system and a dynamic partitioning method in the distributed messaging system. According to an embodiment of the present invention, the dynamic partitioning method in the distributed messaging system may comprise the steps of: determining whether a consumer having no allocated partition exists among a plurality of consumers; equally dividing messages remaining in a first partition in half among the plurality of partitions, creating two new partitions, and storing the equally divided messages in the two new partitions, respectively; allocating the two new partitions to the consumer having no allocated partition and a consumer that was assigned to the first partition, respectively; and updating metadata including list information about partitions and mapping information between each consumer and partitions assigned to each consumer.