If you see similar error when using async aiokafka:
RuntimeError: Compression library for lz4 not found

Install those two packages: pip install lz4 cramjam

For details see here:
https://github.com/aio-libs/aiokafka/blob/master/aiokafka/codec.py#L29