diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2020-09-17 10:41:39 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-17 10:41:39 -0700 |
| commit | 6cfe706d1ab4eaa7c970f19ce102f65625affb96 (patch) | |
| tree | 7a9aa08a6e186c90431897e4e5ac8e9f701eae10 | |
| parent | 16a0b3155fdeebe80295fcfb0f32d75af74dcb1a (diff) | |
| download | kafka-python-6cfe706d1ab4eaa7c970f19ce102f65625affb96.tar.gz | |
Lint cleanup (#2126)
Small cleanup leftover from https://github.com/dpkp/kafka-python/pull/2035
| -rw-r--r-- | kafka/admin/client.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/kafka/admin/client.py b/kafka/admin/client.py index 97fe73a..1fcd88c 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -1,6 +1,6 @@ from __future__ import absolute_import -from collections import defaultdict, namedtuple +from collections import defaultdict import copy import logging import socket @@ -708,7 +708,6 @@ class KafkaAdminClient(object): self._wait_for_futures([future]) response = future.value - return self._convert_create_acls_response_to_acls(acls, response) @staticmethod @@ -1028,7 +1027,6 @@ class KafkaAdminClient(object): assert len(response.groups) == 1 for response_field, response_name in zip(response.SCHEMA.fields, response.SCHEMA.names): if isinstance(response_field, Array): - described_groups = response.__dict__[response_name] described_groups_field_schema = response_field.array_of described_group = response.__dict__[response_name][0] described_group_information_list = [] @@ -1055,7 +1053,8 @@ class KafkaAdminClient(object): described_group_information_list.append(member_information_list) else: described_group_information_list.append(described_group_information) - # Version 3 of the DescribeGroups API introduced the "authorized_operations" field. This will cause the namedtuple to fail + # Version 3 of the DescribeGroups API introduced the "authorized_operations" field. + # This will cause the namedtuple to fail. # Therefore, appending a placeholder of None in it. if response.API_VERSION <=2: described_group_information_list.append(None) |