diff options
Diffstat (limited to 'kafka/consumer/fetcher.py')
| -rw-r--r-- | kafka/consumer/fetcher.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 7112c7e..2c9c0b9 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -6,12 +6,12 @@ import logging import six -import kafka.common as Errors -from kafka.common import TopicPartition +import kafka.errors as Errors from kafka.future import Future from kafka.protocol.fetch import FetchRequest from kafka.protocol.message import PartialMessage from kafka.protocol.offset import OffsetRequest, OffsetResetStrategy +from kafka.structs import TopicPartition log = logging.getLogger(__name__) |