From c666b4e251757b827d52d62f9d4a18ab5e728897 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Mon, 28 May 2018 15:58:26 -0700 Subject: Don't use `kafka.common` internally This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. --- kafka/consumer/multiprocess.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kafka/consumer/multiprocess.py') diff --git a/kafka/consumer/multiprocess.py b/kafka/consumer/multiprocess.py index 1da4a33..758bb92 100644 --- a/kafka/consumer/multiprocess.py +++ b/kafka/consumer/multiprocess.py @@ -8,7 +8,7 @@ import warnings from kafka.vendor.six.moves import queue # pylint: disable=import-error -from kafka.common import KafkaError +from kafka.errors import KafkaError from kafka.consumer.base import ( Consumer, AUTO_COMMIT_MSG_COUNT, AUTO_COMMIT_INTERVAL, @@ -92,7 +92,7 @@ def _mp_consume(client, group, topic, message_queue, size, events, **consumer_op except KafkaError as e: # Retry with exponential backoff - log.error("Problem communicating with Kafka (%s), retrying in %d seconds..." % (e, interval)) + log.exception("Problem communicating with Kafka, retrying in %d seconds...", interval) time.sleep(interval) interval = interval*2 if interval*2 < MAX_BACKOFF_SECONDS else MAX_BACKOFF_SECONDS -- cgit v1.2.1