diff options
Diffstat (limited to 'kafka/codec.py')
| -rw-r--r-- | kafka/codec.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kafka/codec.py b/kafka/codec.py index 9c31e9d..1e57107 100644 --- a/kafka/codec.py +++ b/kafka/codec.py @@ -1,10 +1,12 @@ +from __future__ import absolute_import + import gzip import io import platform import struct -import six -from six.moves import xrange +from kafka.vendor import six +from kafka.vendor.six.moves import xrange # pylint: disable=import-error _XERIAL_V1_HEADER = (-126, b'S', b'N', b'A', b'P', b'P', b'Y', 0, 1, 1) _XERIAL_V1_FORMAT = 'bccccccBii' |