Thanks Joel. Am using version 2.8.0. Thanks, Kashyap
On Tue, Apr 22, 2014 at 5:53 PM, Joel Koshy <jjkosh...@gmail.com> wrote: > 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 > >
