A method for augmenting the capacity of computing resources in a real-time stream computing system, in which computing tasks are transmitted by a distributed message queue, the method being performed by a processor of the system, the method comprising: acquiring a processing status of a first computing unit of the system in processing a first message split cluster included in a computing task and transmitted by the distributed message queue for processing by the first computing unit, wherein: the first message split cluster contains a plurality of message splits, each of the message splits containing one or more messages, and the processing status includes a message processing progress of the first computing unit and a number of messages processed by the first computing unit per second, the message processing progress being a difference between a first time at which a message is processed by the first computing unit and a time at which the message is generated; upon determining, based on the acquired processing status, that the first computing unit has a workload exceeding pre-determined conditions, ranking each message split comprised in the first message split cluster according to the number of messages contained in the message split and splitting the first message split cluster into a number of message split clusters (404, 406) by allocating the message splits from the first message split cluster into the message split clusters (404, 406) based on the ranking of the message splits in the first message split cluster; and assigning the message split clusters (404, 406) obtained by splitting the first message split cluster to a number of second computing units for processing, the number of second computing units corresponding to the number of the message split clusters (404, 406). acquiring a processing status of a first computing unit of the system in processing a first message split cluster included in a computing task and transmitted by the distributed message queue for processing by the first computing unit, wherein: the first message split cluster contains a plurality of message splits, each of the message splits containing one or more messages, and the processing status includes a message processing progress of the first computing unit and a number of messages processed by the first computing unit per second, the message processing progress being a difference between a first time at which a message is processed by the first computing unit and a time at which the message is generated; the first message split cluster contains a plurality of message splits, each of the message splits containing one or more messages, and the processing status includes a message processing progress of the first computing unit and a number of messages processed by the first computing unit per second, the message processing progress being a difference between a first time at which a message is processed by the first computing unit and a time at which the message is generated; upon determining, based on the acquired processing status, that the first computing unit has a workload exceeding pre-determined conditions, ranking each message split comprised in the first message split cluster according to the number of messages contained in the message split and splitting the first message split cluster into a number of message split clusters (404, 406) by allocating the message splits from the first message split cluster into the message split clusters (404, 406) based on the ranking of the message splits in the first message split cluster; and assigning the message split clusters (404, 406) obtained by splitting the first message split cluster to a number of second computing units for processing, the number of second computing units corresponding to the number of the message split clusters (404, 406).