summaryrefslogtreecommitdiff
path: root/kafka/client_async.py
diff options
context:
space:
mode:
authorJames Lamb <jaylamb20@gmail.com>2017-08-30 00:45:04 -0500
committerJeff Widman <jeff@jeffwidman.com>2017-08-29 22:45:04 -0700
commit24bf504cd894c85a861c6691e778359220e40323 (patch)
tree4ed09c94f053fd6e2e69a02e084dd91f7c3a7d63 /kafka/client_async.py
parentba7afd9bc9362055ec0bedcf53eb6f8909dc22d2 (diff)
downloadkafka-python-24bf504cd894c85a861c6691e778359220e40323.tar.gz
Remove a few unused imports (#1188)
* Removed a few unused imports * Added note on socketpair monkey-path
Diffstat (limited to 'kafka/client_async.py')
-rw-r--r--kafka/client_async.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py
index 80e8494..f6fe829 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -28,7 +28,8 @@ from .metrics import AnonMeasurable
from .metrics.stats import Avg, Count, Rate
from .metrics.stats.rate import TimeUnit
from .protocol.metadata import MetadataRequest
-from .protocol.produce import ProduceRequest
+# Although this looks unused, it actually monkey-patches socket.socketpair()
+# and should be left in as long as we're using socket.socketpair() in this file
from .vendor import socketpair
from .version import __version__