Another thing is that the active log segment would not be deleted, so if there is only one log segment, it will not honor the retention policy. You may config log.roll.ms to make sure you have a rolled over log segment.
On 4/3/15, 5:20 AM, "Madhukar Bharti" <bhartimadhu...@gmail.com> wrote: >Hi Gaurav, > >What is your "log.retention.check.interval.ms" ? There might be a chance >it >will be high so it is not able to delete in specified interval. > >And also in Kafka 0.8.1 it will be "retention.ms". Please check this ><http://kafka.apache.org/081/documentation.html#topic-config> > >Regards, >Madhukar > >On Fri, Apr 3, 2015 at 5:01 PM, Gaurav Agarwal <gaurav130...@gmail.com> >wrote: > >> hello group, >> I have created a topic with the delete retention ms time 1000 and send >> and consume message across. Nothing happened after that , i checked >> the log also , message also not deleted as well. Please help me to >> come to know what is the need >>
