diff options
Diffstat (limited to 'kafka/consumer/simple.py')
| -rw-r--r-- | kafka/consumer/simple.py | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index 946e9c7..abeac7b 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -5,14 +5,11 @@ try: except ImportError: from itertools import izip_longest as izip_longest, repeat # pylint: disable=E0611 import logging -try: - import queue # python 3 -except ImportError: - import Queue as queue # python 2 import sys import time import six +from six.moves import queue from .base import ( Consumer, |