Re: Unable to set log.cleanup.policy on topic

2015-12-07 Thread Rakesh Vidyadharan
Duh…, did note the difference in property naming there. Thanks, was able to set the property. On 07/12/2015 14:37, "Stevo Slavić" wrote: >Hello Rakesh, > >log.cleanup.policy is broker configuration property, while cleanup.policy >is topic configuration property (see >http://kafka.apache.org

Re: Unable to set log.cleanup.policy on topic

2015-12-07 Thread Ofir Manor
Hi, log.cleanup.policy is the server-level parameter. The per-topic parameter you are looking for is just cleanup.policy See here - http://kafka.apache.org/documentation.html#topic-config Also, it is listed in the help: $ kafka-topics.sh Create, delete, describe, or change a topic. Option

Re: Unable to set log.cleanup.policy on topic

2015-12-07 Thread Stevo Slavić
Hello Rakesh, log.cleanup.policy is broker configuration property, while cleanup.policy is topic configuration property (see http://kafka.apache.org/documentation.html#topic-config ). Since you are configuring particular topic, you need to use second one. Kind regards, Stevo Slavic. On Mon, Dec

Unable to set log.cleanup.policy on topic

2015-12-07 Thread Rakesh Vidyadharan
Hello, I upgraded to the latest 0.8 release 0.8.2.2, and tried to set the log cleanup policy on some of our topics (I got same error with 0.8.1, but thought it may have been some issue with that release). /opt/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic metamorphosis.t