summaryrefslogtreecommitdiff
path: root/kafka/client_async.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/client_async.py')
-rw-r--r--kafka/client_async.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py
index 27ef01a..cbda846 100644
--- 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: