diff options
| -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 |