From 89243509b28d744ab26e8b67e1e2c9b74b4d902f Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Mon, 19 Nov 2018 11:04:51 -0800 Subject: Bugfix: Always set this_groups_coordinator_id --- kafka/admin/kafka.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 -- cgit v1.2.1