summaryrefslogtreecommitdiff
path: root/kafka/consumer/simple.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/consumer/simple.py')
-rw-r--r--kafka/consumer/simple.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py
index 3de0dee..f5b6a99 100644
--- a/kafka/consumer/simple.py
+++ b/kafka/consumer/simple.py
@@ -9,8 +9,8 @@ import sys
import time
import warnings
-import six
-from six.moves import queue
+from kafka.vendor import six
+from kafka.vendor.six.moves import queue # pylint: disable=import-error
from .base import (
Consumer,