diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2018-11-19 11:04:51 -0800 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-11-19 11:08:05 -0800 |
| commit | 89243509b28d744ab26e8b67e1e2c9b74b4d902f (patch) | |
| tree | 8853d2db2b18bc18f15268f829e442f620e2045f | |
| parent | 24f41315889c23a5ea7d0ae26c3bbd8d68ae062c (diff) | |
| download | kafka-python-89243509b28d744ab26e8b67e1e2c9b74b4d902f.tar.gz | |
Bugfix: Always set this_groups_coordinator_id
| -rw-r--r-- | kafka/admin/kafka.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/kafka/admin/kafka.py b/kafka/admin/kafka.py index 8e0a756..c8abb4e 100644 --- a/kafka/admin/kafka.py +++ b/kafka/admin/kafka.py @@ -593,7 +593,9 @@ class KafkaAdmin(object): group_descriptions = [] version = self._matching_api_version(DescribeGroupsRequest) for group_id in group_ids: - if group_coordinator_id is None: + if group_coordinator_id is not None: + this_groups_coordinator_id = group_coordinator_id + else: this_groups_coordinator_id = self._find_group_coordinator_id(group_id) if version <= 1: # Note: KAFKA-6788 A potential optimization is to group the |