Move kafka.socketpair to kafka.vendor.socketpair

2016-08-01 09:44:31 -07:00
parent 4828e491f1
commit 1d23dddcd6
2 changed files with 1 additions and 1 deletions
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -28,7 +28,7 @@ from .metrics.stats import Avg, Count, Rate
 from .metrics.stats.rate import TimeUnit
 from .protocol.metadata import MetadataRequest
 from .protocol.produce import ProduceRequest
-from . import socketpair
+from .vendor import socketpair
 from .version import __version__

 if six.PY2:
--- a/kafka/vendor/socketpair.py
+++ b/kafka/vendor/socketpair.py