I have a question about kafka, could you please help to have a look?

I want to send a message from producer with snappy compression codec. So I run 
the command "bin/kafka-console-producer.sh --compression-codec snappy 
--broker-list localhost:9092 --topic test", after that I checked the data log, 
compresscodec is SnappyCompressionCodec as expectation.

Then I tried another command "bin/kafka-console-producer.sh --producer-property 
compression.type=snappy --broker-list localhost:9092 --topic test" to send a 
message from producer with snappy also, but this time I found compresscodec is 
NoCompressionCodec in data log.
I double checked the option of "kafka-console-producer.sh" as below, seems both 
"--compression-codec" and "--producer-property" could be used to set up 
compression codec, why the second way failed? The "key=value" I found in 
config/producer.properties, so I think it is regular. Thanks!

# bin/kafka-console-producer.sh --help

--compression-codec [compression-codec] The compression codec: either 
'none','gzip', 'snappy', or 'lz4'.If specified without value, then it defaults 
to 'gzip'.

--producer-property <producer_prop>      A mechanism to pass user-defined 
properties in the form key=value to the producer.

--producer.config <config file>          Producer config properties file. Note 
that [producer-property] takes precedence over this config.

Best Regards


Reply via email to