summaryrefslogtreecommitdiff
path: root/kafka/consumer/multiprocess.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-06-08 17:21:28 -0700
committerDana Powers <dana.powers@rd.io>2015-06-08 18:59:23 -0700
commita9ddf155e7f9c94be3c4b7508946158aa1900466 (patch)
tree2527484c7b1bf3d2c6ccb38dbd590891f3d6d9c7 /kafka/consumer/multiprocess.py
parent3d4d98ed78414af0c4330f056a3ae6bcf79ed11c (diff)
downloadkafka-python-a9ddf155e7f9c94be3c4b7508946158aa1900466.tar.gz
Cleanup imports in kafka/client and kafka/consumer
Diffstat (limited to 'kafka/consumer/multiprocess.py')
-rw-r--r--kafka/consumer/multiprocess.py15
1 files changed, 7 insertions, 8 deletions
diff --git a/kafka/consumer/multiprocess.py b/kafka/consumer/multiprocess.py
index 8cec92d..d03eb95 100644
--- a/kafka/consumer/multiprocess.py
+++ b/kafka/consumer/multiprocess.py
@@ -1,22 +1,21 @@
from __future__ import absolute_import
-import logging
-import time
-
from collections import namedtuple
+import logging
from multiprocessing import Process, Manager as MPManager
-
try:
- from Queue import Empty, Full
-except ImportError: # python 2
- from queue import Empty, Full
+ from Queue import Empty, Full # python 3
+except ImportError:
+ from queue import Empty, Full # python 2
+import time
from .base import (
+ Consumer,
AUTO_COMMIT_MSG_COUNT, AUTO_COMMIT_INTERVAL,
NO_MESSAGES_WAIT_TIME_SECONDS,
FULL_QUEUE_WAIT_TIME_SECONDS
)
-from .simple import Consumer, SimpleConsumer
+from .simple import SimpleConsumer
log = logging.getLogger(__name__)