summaryrefslogtreecommitdiff
path: root/kafka/partitioner/hashed.py
diff options
context:
space:
mode:
authorBrian Sang <sang.bri@gmail.com>2019-05-22 23:54:14 -0700
committerJeff Widman <jeff@jeffwidman.com>2019-05-22 23:54:14 -0700
commit1f73287e890a4c68f240dcc8b6966de1e62b65cc (patch)
tree6e9f76a1412598475a60e0c3101066566542faf5 /kafka/partitioner/hashed.py
parentedfafc036f0d9a3b1e5c73f9642ef71c297c1b64 (diff)
downloadkafka-python-1f73287e890a4c68f240dcc8b6966de1e62b65cc.tar.gz
Make partitions_for_topic a read-through cache (#1781)
If the cluster metadata object has no info about the topic, then issue a blocking metadata call to fetch it.
Diffstat (limited to 'kafka/partitioner/hashed.py')
0 files changed, 0 insertions, 0 deletions