Hello Akash, It's the same on the broker side as well.
*Broker side config:-* compression.type=snappy On Mon, Aug 26, 2024 at 9:30 PM Akash Jain <akashjain0...@gmail.com> wrote: > And what is it on broker? > > On Sunday, August 25, 2024, Vikram Singh <vikram.si...@nciportal.com > .invalid> > wrote: > > > Hello Akash, > > > > > > Yes, i am using compression type in producer side configuration as > > mentioned below, > > > > And the compression type I am using is *snappy*. > > > > > > *Compression on producer :-* > > > > producerProperties.put("compression.type",CloudKafkaProducerConfig. > > COMPRESSION_TYPE); > > > > On Fri, Aug 23, 2024 at 5:56 PM Akash Jain <akashjain0...@gmail.com> > > wrote: > > > > > Hi Vikram. Can you share you code snippet? Are you using compression on > > > producer/broker side? > > > > > > On Friday, August 23, 2024, Vikram Singh <vikram.si...@nciportal.com > > > .invalid> > > > wrote: > > > > > > > Hello, > > > > > > > > I am facing issues while producing messages on kafka topics. I am > > facing > > > > this issue randomly. Please help me by referring to the logs below. > > > > > > > > Logs :- > > > > 1). ERROR [ReplicaManager broker=0] Error processing append operation > > on > > > > partition MHM_CLZ_COM-AWS_123-7 (kafka.server.ReplicaManager) > > > > > > > > org.apache.kafka.common.KafkaException: Failed to decompress record > > > stream > > > > > > > > 2). Caused by: java.io.IOException: FAILED_TO_UNCOMPRESS(5) > > > > > > > > > >