Thanks Nicolas. This helps. On Fri, Apr 10, 2020 at 7:59 PM Nicolas Carlot <nicolas.car...@chronopost.fr> wrote:
> Ok, then you may be looking for custom headers: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers > > > Le ven. 10 avr. 2020 à 16:08, Naveen Kumar M <eai.naveenkuma...@gmail.com> > a écrit : > > > Hello Nicolas, > > > > Thanks a lot for the response. "Custom properties" are nothing but > > additional message properties based on our requirement and which are not > > part of message payload. For example trackingId which I need to add this > > additional property while producing message and read the same in consumer > > end. > > > > In JMS messaging system, we can add JMS Custom properties while sending > > messages to consumer and consumer can read the same. I am looking for > > similar functionality in Kafka. > > > > Thanks and regards, > > Naveen > > > > On Fri, Apr 10, 2020, 7:22 PM Nicolas Carlot < > nicolas.car...@chronopost.fr > > > > > wrote: > > > > > Hello, > > > > > > Message expiration is based on topic configuration, not on your > producer > > > configuration. > > > Look at kafka server configuration. retention.ms is one of the > > properties > > > that drive the message deletion > > > I don't know what is "customer properties", if you're talking about > > "custom > > > properties", what do you mean by reading them on the consumer end ? > > > > > > Le ven. 10 avr. 2020 à 15:46, Naveen Kumar M < > > eai.naveenkuma...@gmail.com> > > > a écrit : > > > > > > > Hello Team, > > > > > > > > Could you please help me on this? > > > > > > > > Thanks and regards, > > > > Naveen > > > > > > > > On Tue, Apr 7, 2020, 2:27 PM Naveen Kumar M < > > eai.naveenkuma...@gmail.com > > > > > > > > wrote: > > > > > > > > > Hello Friends, > > > > > > > > > > Hope you are all doing good! > > > > > > > > > > I am bit new to Kafka messaging system. > > > > > > > > > > We are using Kafka as messaging broker. > > > > > > > > > > Could someone let me know how to set custom properties and message > > > > > expiration while sending message to Kafka topic and how to read > > > customer > > > > > properties in consumer end? > > > > > > > > > > Thanks and regards, > > > > > Naveen > > > > > > > > > > > > > > > > > > -- > > > *Nicolas Carlot* > > > > > > Lead dev > > > | | nicolas.car...@chronopost.fr > > > > > > > > > *Veuillez noter qu'à partir du 20 mai, le siège Chronopost déménage. La > > > nouvelle adresse est : 3 boulevard Romain Rolland 75014 Paris* > > > > > > [image: Logo Chronopost] > > > | chronopost.fr <http://www.chronopost.fr/> > > > Suivez nous sur Facebook <https://fr-fr.facebook.com/chronopost> et > > > Twitter > > > <https://twitter.com/chronopost>. > > > > > > [image: DPD Group] > > > > > > > > -- > *Nicolas Carlot* > > Lead dev > | | nicolas.car...@chronopost.fr > > > *Veuillez noter qu'à partir du 20 mai, le siège Chronopost déménage. La > nouvelle adresse est : 3 boulevard Romain Rolland 75014 Paris* > > [image: Logo Chronopost] > | chronopost.fr <http://www.chronopost.fr/> > Suivez nous sur Facebook <https://fr-fr.facebook.com/chronopost> et > Twitter > <https://twitter.com/chronopost>. > > [image: DPD Group] >
