Hello Xuechao, We do not support decoupling compression from producer to broker side now, but this feature is part of the client-rewrite project that is being worked on right now.
https://cwiki.apache.org/confluence/display/KAFKA/Client+Rewrite #ClientRewrite-ProposedProducerAPI Guozhang On Mon, Oct 21, 2013 at 11:47 AM, Lu Xuechao <lux...@gmail.com> wrote: > Hi, > > I wonder if it is supported to enable compression for storage on brokers > but the producer sends messages uncompressed and consumer receives messages > uncompressed? > > thanks. > -- -- Guozhang
