Kafka compression issues

Hi, I use kafka 0.8. When I run the kafka console producer using ./kafka-console-producer.sh --topic test.compress.e --compress true --broker-list 127.0.0.1:9092 Iam able to see compressed messages in the log. But when I run a Java producer class using the following properties, no

Re: Kafka compression issues

Any error in the producer and the broker log (including state-change.log)? Thanks, Jun On Tue, Jul 9, 2013 at 12:31 PM, arathi maddula arathimadd...@gmail.comwrote: Hi, I use kafka 0.8. When I run the kafka console producer using ./kafka-console-producer.sh --topic test.compress.e