summaryrefslogtreecommitdiff
path: root/test/test_assignors.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2020-09-17 12:15:08 -0700
committerGitHub <noreply@github.com>2020-09-17 12:15:08 -0700
commit098ecbfd79ce8919c1d3dec50a207bbbe62c894c (patch)
tree3df34d5cd0dac2dfd0df52e07f65ca6686c35b6e /test/test_assignors.py
parent6cfe706d1ab4eaa7c970f19ce102f65625affb96 (diff)
downloadkafka-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