Home
last modified time | relevance | path

Searched refs:leader_for_partition (Results 1 – 3 of 3) sorted by relevance

/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/
H A Dcluster.py129 def leader_for_partition(self, partition): member in ClusterMetadata
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/consumer/
H A Dfetcher.py507 node_id = self._client.cluster.leader_for_partition(partition)
653 node_id = self._client.cluster.leader_for_partition(partition)
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/producer/
H A Drecord_accumulator.py391 leader = cluster.leader_for_partition(tp)