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
