Lint cleanup (#2126)

Small cleanup leftover from #2035

Author: jeffwidman

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 @@ def create_acls(self, acls):
         self._wait_for_futures([future])
         response = future.value
 
-
         return self._convert_create_acls_response_to_acls(acls, response)
 
     @staticmethod
@@ -1028,7 +1027,6 @@ def _describe_consumer_groups_process_response(self, response):
             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 @@ def _describe_consumer_groups_process_response(self, response):
                             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)