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