1. A computer-implemented method, comprising: selecting, based on a request received from a client node, a data partition in a plurality of data partitions of a data stream, the request identifying the data stream, the plurality of data partitions arranged using a rooted acyclic directed graph and distributed among a plurality of broker nodes in a distributed messaging system, the selected data partition based further on a first distance between a root partition of the acyclic directed graph and the selected data partition being greater than a second distance between the root partition and a previously selected partition of the data stream, wherein the first distance and the second distance are positive integer values greater than zero; identifying a broker node in the plurality of broker nodes hosting the selected data partition; and providing, by the identified broker node, the selected data partition to the client node for performing at least one function; wherein at least one of the selecting, the identifying, and the providing is performed using at least one processor of at least one computing system.