Which version of Kafka are you using? You can read up on the configuration options here: http://kafka.apache.org/documentation.html#configuration
You can specify time-based retention using log.retention.minutes which will apply to all topics. You can override that on per-topic basis - see further down in the above page under "topic-level configuration" On Tue, Apr 22, 2014 at 02:34:24PM -0500, Kashyap Mhaisekar wrote: > Hi, > I wanted to set the message expiry for a message on a kafka topic. Is there > anything like this in kafka? > I came across a property - *log.retention.hours* and > *topic.log.retention.hours* > Had some queries around it.And it was mentioned that > topic.log.retention.hours is per topic configuration. > Had some queries around it - > 1. Does it mean that I need to specific the <topicname>.log.retention.hours > in the kafka config? > 2. Can this property be overriden anywhere? > 3. Is it possible for the producer to set a message expiry so that the > message expires after a configurable period of time? > > Regards, > Kashyap
