LZ4 Compression fails with lz4 version 0.10.1

[ghop02]

PyKafka version: 2.8.0 Kafka version: 0.11.1

In [8]: lz4.__version__
Out[8]: '0.10.1'

In [9]: compression.encode_lz4(memoryview(bytearray(b"")))
---------------------------------------------------------------------------
TypeError                                 Traceback (most recent call last)
<ipython-input-9-0d1d70f0048d> in <module>
----> 1 compression.encode_lz4(memoryview(bytearray(b"")))

TypeError: argument 1 must be read-only bytes-like object, not memoryview

Upgrading lz4 should fix the issue!

In [5]: lz4.__version__
Out[5]: '2.2.1'

In [6]: compression.encode_lz4(memoryview(bytearray(b"")))
Out[6]: b'\x04"M\x18`@\x82\x00\x00\x00\x00'