diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2019-07-30 18:35:02 -0700 |
---|---|---|
committer | Jeff Widman <jeff@jeffwidman.com> | 2019-07-31 11:26:43 -0700 |
commit | ea35fdfe1d66eb481e3406ad161a1255573dd50f (patch) | |
tree | c2694603458875f807c7ff6c4eacfe98b65fd410 /kafka/protocol/api.py | |
parent | eed25fc36110b12ec370b4d0e332173abce9076f (diff) | |
download | kafka-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