Bugfix: Always set this_groups_coordinator_id

dpkp · Nov 19, 2018 · 8924350 · 8924350
1 parent 24f4131
commit 8924350
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/kafka/admin/kafka.py b/kafka/admin/kafka.py
@@ -593,7 +593,9 @@ def describe_consumer_groups(self, group_ids, group_coordinator_id=None):
         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