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/simple.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'kafka/consumer/simple.py') diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index c0c1b1e..b60a586 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -24,13 +24,13 @@ from kafka.consumer.base import ( ITER_TIMEOUT_SECONDS, NO_MESSAGES_WAIT_TIME_SECONDS ) -from kafka.common import ( - FetchRequestPayload, KafkaError, OffsetRequestPayload, - ConsumerFetchSizeTooSmall, +from kafka.errors import ( + KafkaError, ConsumerFetchSizeTooSmall, UnknownTopicOrPartitionError, NotLeaderForPartitionError, OffsetOutOfRangeError, FailedPayloadsError, check_error ) from kafka.protocol.message import PartialMessage +from kafka.structs import FetchRequestPayload, OffsetRequestPayload log = logging.getLogger(__name__) -- cgit v1.2.1