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]