Re: Log Retention in Kafka

Dynamically changing configs per topic is only available in 0.8.1. You can try the latest release 0.8.1.1. Thanks, Jun On Mon, May 5, 2014 at 12:28 PM, Kashyap Mhaisekar wrote: > Thanks Jun. I am using kafka_2.8.0-0.8.0-beta1.jar. I dont see this script > kafka-topic.sh in the bin folder. Is t

Re: Log Retention in Kafka

Thanks Jun. I am using kafka_2.8.0-0.8.0-beta1.jar. I dont see this script kafka-topic.sh in the bin folder. Is there way to do this in the version mentioned? --Kashyap On Mon, May 5, 2014 at 11:18 AM, Jun Rao wrote: > See http://kafka.apache.org/documentation.html#basic_ops_modify_topic > > T

Re: Log Retention in Kafka

See http://kafka.apache.org/documentation.html#basic_ops_modify_topic Thanks, Jun On Sun, May 4, 2014 at 10:11 PM, Kashyap Mhaisekar wrote: > Is there a way to do this at runtime using some available scripts in > kafka/bin? If so, any pointers on which script? > > Regards, > Kashyap > > > On T

Re: Log Retention in Kafka

Is there a way to do this at runtime using some available scripts in kafka/bin? If so, any pointers on which script? Regards, Kashyap On Tue, Apr 22, 2014 at 11:11 PM, Kashyap Mhaisekar wrote: > Thanks Joel. Am using version 2.8.0. > > Thanks, > Kashyap > > > On Tue, Apr 22, 2014 at 5:53 PM, Jo

Re: Log Retention in Kafka

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

Re: Log Retention in Kafka

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

Log Retention in Kafka

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. Ha