Live resegmenting of partitions in distributed stream-processing platforms

A method, comprising:

• upon receiving a trigger to move a partition of a distributed stream-processing platform from a first broker on a first set of physical resources to a second broker on a second a set of physical resources, allocating the partition on the second broker;
• configuring, by a computer system, the first broker to redirect, to the second broker, requests for new messages after a last offset in the partition without replicating older messages before the last offset to the second broker;
• and
• updating metadata for processing requests for the partition to include the second broker.

An apparatus, comprising:

• one or more processors;
• and
• memory storing instructions that, when executed by the one or more processors, cause the apparatus to:
• upon receiving a trigger to move a partition of a distributed stream-processing platform from a first broker on a first set of physical resources to a second broker on a second a set of physical resources, allocate the partition on the second broker;
• configure the first broker to redirect, to the second broker, requests for new messages after a last offset in the partition without replicating older messages before the last offset to the second broker;
• and
• update metadata for processing requests for the partition to include the second broker.