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 cbda846..dd4df82 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -18,7 +18,7 @@ except ImportError:
import socket
import time
-import six
+from kafka.vendor import six
from .cluster import ClusterMetadata
from .conn import BrokerConnection, ConnectionStates, collect_hosts, get_ip_port_afi