diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2020-09-17 12:15:08 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-09-17 12:15:08 -0700 |
commit | 098ecbfd79ce8919c1d3dec50a207bbbe62c894c (patch) | |
tree | 3df34d5cd0dac2dfd0df52e07f65ca6686c35b6e /test/test_assignors.py | |
parent | 6cfe706d1ab4eaa7c970f19ce102f65625affb96 (diff) | |
download | kafka-python-098ecbfd79ce8919c1d3dec50a207bbbe62c894c.tar.gz |
Merge _find_coordinator_id methods (#2127)
Previously there were two methods:
* `_find_coordinator_id()`
* `_find_many_coordinator_ids()`
But they do basically the same thing internally. And we need the plural
two places, but the singular only one place.
So merge them, and change the function signature to take a list of
`group_ids` and return a dict of `group_id: coordinator_id`s.
As a result of this, the `describe_groups()` command should scale better
because the `_find_coordinator_ids()` command issues all the requests
async, instead of sequentially blocking as the `described_groups()` used
to do.
Diffstat (limited to 'test/test_assignors.py')
0 files changed, 0 insertions, 0 deletions