HI All,

My Kafka version is: kafka_2.9.2-0.8.1.1

I used topic.log.retention.hours to define the topic specific retention hours, 
but it haven't trigger the deletion of outdated logs.
Below are my settings:
log.retention.hours=12
topic.log.retention.hours=ssnzEvent:1

the general retention hours is 12 hours, for ssnzEvent it's 1 hour.  For 
ssnzEvent topic, it haven't trigger the deletion even for 10 hours file.
Do you know the reason, what's the correct usage for topic.log.retention.hours?

Thanks,
Warren







Reply via email to