Searched refs:leader_for_partition (Results 1 – 3 of 3) sorted by relevance
129 def leader_for_partition(self, partition): member in ClusterMetadata
507 node_id = self._client.cluster.leader_for_partition(partition)653 node_id = self._client.cluster.leader_for_partition(partition)
391 leader = cluster.leader_for_partition(tp)