kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rakesh Vidyadharan <rvidyadha...@gracenote.com>
Subject Re: Unable to set log.cleanup.policy on topic
Date Mon, 07 Dec 2015 20:47:00 GMT
Duh…, did note the difference in property naming there.  Thanks, was able to set the property.




On 07/12/2015 14:37, "Stevo Slavić" <sslavic@gmail.com> wrote:

>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 7, 2015 at 8:59 PM, Rakesh Vidyadharan <
>rvidyadharan@gracenote.com> wrote:
>
>> 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.team --config log.cleanup.policy=compact
>>
>> It gives me the following error (it looked identical on 0.8.1 as well)
>>
>> Error while executing topic command requirement failed: Unknown
>> configuration "log.cleanup.policy".
>> java.lang.IllegalArgumentException: requirement failed: Unknown
>> configuration "log.cleanup.policy".
>> at scala.Predef$.require(Predef.scala:233)
>> at kafka.log.LogConfig$$anonfun$validateNames$1.apply(LogConfig.scala:183)
>> at kafka.log.LogConfig$$anonfun$validateNames$1.apply(LogConfig.scala:182)
>> at scala.collection.Iterator$class.foreach(Iterator.scala:727)
>> at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
>> at kafka.log.LogConfig$.validateNames(LogConfig.scala:182)
>> at kafka.log.LogConfig$.validate(LogConfig.scala:190)
>> at
>> kafka.admin.TopicCommand$.parseTopicConfigsToBeAdded(TopicCommand.scala:205)
>> at
>> kafka.admin.TopicCommand$$anonfun$alterTopic$1.apply(TopicCommand.scala:103)
>> at
>> kafka.admin.TopicCommand$$anonfun$alterTopic$1.apply(TopicCommand.scala:100)
>> at
>> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
>> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
>> at kafka.admin.TopicCommand$.alterTopic(TopicCommand.scala:100)
>> at kafka.admin.TopicCommand$.main(TopicCommand.scala:57)
>> at kafka.admin.TopicCommand.main(TopicCommand.scala)
>>
>> The documentation indicates this can be modified after topic is created,
>> not sure if that means we can modify the setting after messages have been
>> posted to the topic, which is what we are trying to do.
>>
>> Thanks
>> Rakesh
>>
Mime
View raw message