1. A computer-implemented method, comprising: selecting a data partition in a plurality of data partitions of data stream based on a request received from a client processing node, the plurality of data partitions are distributed among a plurality of broker nodes in a distributed messaging system; 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 processing 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.