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)
> > > >
> > >
> >
>
