diff options
Diffstat (limited to 'kafka/codec.py')
| -rw-r--r-- | kafka/codec.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/codec.py b/kafka/codec.py index 5adb2e5..09075e1 100644 --- a/kafka/codec.py +++ b/kafka/codec.py @@ -102,8 +102,10 @@ def snappy_encode(payload, xerial_compatible=True, xerial_blocksize=32*1024): # Chunk through buffers to avoid creating intermediate slice copies if six.PY2: + # pylint: disable-msg=undefined-variable chunker = lambda payload, i, size: buffer(payload, i, size) else: + # pylint: disable-msg=undefined-variable chunker = lambda payload, i, size: memoryview(payload)[i:size+i].tobytes() for chunk in (chunker(payload, i, xerial_blocksize) |