Compression in confluent kafka

When we use compression.type as lz4 in confluent kafka, properties in databricks notebook. The compression is not happening and kafka gives an error message size to bog