summaryrefslogtreecommitdiff
path: root/kafka
diff options
context:
space:
mode:
authorJames Lamb <jaylamb20@gmail.com>2020-05-10 23:40:06 -0500
committerJeff Widman <jeff@jeffwidman.com>2020-07-10 22:38:08 -0700
commit316da747e432962d149828cb9d6fbaff04c2008c (patch)
tree9d23ab672d86e96099707ebb1fd19edb378c7532 /kafka
parentf5a99fa85e0a94336c6dcdc91cc44701e1b46d19 (diff)
downloadkafka-python-316da747e432962d149828cb9d6fbaff04c2008c.tar.gz
remove unused imports
Diffstat (limited to 'kafka')
-rw-r--r--kafka/client_async.py1
-rw-r--r--kafka/coordinator/base.py1
-rw-r--r--kafka/scram.py1
3 files changed, 0 insertions, 3 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py
index 5379153..caa88cf 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -2,7 +2,6 @@ from __future__ import absolute_import, division
import collections
import copy
-import functools
import logging
import random
import socket
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
index b0e236a..cd110ce 100644
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -3,7 +3,6 @@ from __future__ import absolute_import, division
import abc
import copy
import logging
-import sys
import threading
import time
import weakref
diff --git a/kafka/scram.py b/kafka/scram.py
index 684925c..7f00375 100644
--- a/kafka/scram.py
+++ b/kafka/scram.py
@@ -71,7 +71,6 @@ class ScramClient:
)
def final_message(self):
- client_final_no_proof = 'c=biws,r=' + self.nonce
return 'c=biws,r={},p={}'.format(self.nonce, base64.b64encode(self.client_proof).decode('utf-8'))
def process_server_final_message(self, server_final_message):