diff options
Diffstat (limited to 'kafka/protocol/legacy.py')
| -rw-r--r-- | kafka/protocol/legacy.py | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/kafka/protocol/legacy.py b/kafka/protocol/legacy.py index f2ae44a..6d9329d 100644 --- a/kafka/protocol/legacy.py +++ b/kafka/protocol/legacy.py @@ -3,9 +3,7 @@ from __future__ import absolute_import import logging import struct -from kafka.vendor import six # pylint: disable=import-error - -from kafka.vendor.six.moves import xrange # pylint: disable=import-error +from kafka.vendor import six # pylint: disable=import-error import kafka.protocol.commit import kafka.protocol.fetch @@ -15,13 +13,12 @@ import kafka.protocol.offset import kafka.protocol.produce import kafka.structs -from kafka.codec import ( - gzip_encode, gzip_decode, snappy_encode, snappy_decode) -from kafka.errors import ProtocolError, ChecksumError, UnsupportedCodecError +from kafka.codec import gzip_encode, snappy_encode +from kafka.errors import ProtocolError, UnsupportedCodecError from kafka.structs import ConsumerMetadataResponse from kafka.util import ( - crc32, read_short_string, read_int_string, relative_unpack, - write_short_string, write_int_string, group_by_topic_and_partition) + crc32, read_short_string, relative_unpack, + write_int_string, group_by_topic_and_partition) log = logging.getLogger(__name__) @@ -320,7 +317,6 @@ class KafkaProtocol(object): for partition, payload in six.iteritems(topic_payloads)]) for topic, topic_payloads in six.iteritems(group_by_topic_and_partition(payloads))]) - @classmethod def decode_offset_commit_response(cls, response): """ |