diff options
Diffstat (limited to 'kafka/consumer/multiprocess.py')
| -rw-r--r-- | kafka/consumer/multiprocess.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/consumer/multiprocess.py b/kafka/consumer/multiprocess.py index 58e3e07..1da4a33 100644 --- a/kafka/consumer/multiprocess.py +++ b/kafka/consumer/multiprocess.py @@ -8,15 +8,15 @@ import warnings from kafka.vendor.six.moves import queue # pylint: disable=import-error -from ..common import KafkaError -from .base import ( +from kafka.common import KafkaError +from kafka.consumer.base import ( Consumer, AUTO_COMMIT_MSG_COUNT, AUTO_COMMIT_INTERVAL, NO_MESSAGES_WAIT_TIME_SECONDS, FULL_QUEUE_WAIT_TIME_SECONDS, MAX_BACKOFF_SECONDS, ) -from .simple import SimpleConsumer +from kafka.consumer.simple import SimpleConsumer log = logging.getLogger(__name__) |