compression.codec property is not working

[spaluri]

tried setting compression.codec to 2 snappy , but we still see msg is not being compressed. also added topic name to compression.topic property, we could see msg in plain text, not sure why its not compressing

[spektom]

Hi @spaluri Kafka consumer transparently decompresses messages. How do you know it's not internally compressed?

[spaluri]

hi @spektom , we tried setting compression.codec to 2 in the properties, and publish msg , i would not publish anything to brokers, as soon we unset the property to default it publishes msg to broker. seems like msgs are not even making it to broker.

[spaluri]

screenshot of the config