summaryrefslogtreecommitdiff
path: root/kafka/protocol/api.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2019-07-30 18:35:02 -0700
committerJeff Widman <jeff@jeffwidman.com>2019-07-31 11:26:43 -0700
commitea35fdfe1d66eb481e3406ad161a1255573dd50f (patch)
treec2694603458875f807c7ff6c4eacfe98b65fd410 /kafka/protocol/api.py
parenteed25fc36110b12ec370b4d0e332173abce9076f (diff)
downloadkafka-python-ea35fdfe1d66eb481e3406ad161a1255573dd50f.tar.gz
Break FindCoordinator into request/response methods
This splits the `_find_coordinator_id()` method (which is blocking) into request generation / response parsing methods. The public API does not change. However, this allows power users who are willing to deal with risk of private methods changing under their feet to decouple generating the message futures from processing their responses. In other words, you can use these to fire a bunch of requests at once and delay processing the responses until all requests are fired. This is modeled on the work done in #1845. Additionally, I removed the code that tried to leverage the error checking from `cluster.add_group_coordinator()`. That code had changed in #1822, removing most of the error checking... so it no longer adds any value, but instead merely increases complexity and coupling.
Diffstat (limited to 'kafka/protocol/api.py')
0 files changed, 0 insertions, 0 deletions