Hi, We are on Kafka version 1.0.0. Per the below new feature, a topic can allow both compact and delete. I tried all the combinations, but they all fail to accept values that are not either compact OR delete. Is this feature valid in updated releases, since 0.10.2? If this is not a feature available, how to cleanup the growing compacted topic scenario?
https://issues.apache.org/jira/browse/KAFKA-4015 $ ./kafka-configs.sh --zookeeper <<XXXXX>>:2181--alter --entity-type topics --entity-name stream_output --add-config cleanup.policy=compact,delete Error while executing config command requirement failed: Invalid entity config: all configs to be added must be in the format "key=val". java.lang.IllegalArgumentException: requirement failed: Invalid entity config: all configs to be added must be in the format "key=val". at scala.Predef$.require(Predef.scala:233) at kafka.admin.ConfigCommand$.parseConfigsToBeAdded(ConfigCommand.scala:128) at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:78) at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:65) at kafka.admin.ConfigCommand.main(ConfigCommand.scala) $ ./kafka-configs.sh --zookeeper <<XXXXX>>:2181 --alter --entity-type topics --entity-name ash_stream_output --add-config cleanup.policy=compact_delete Error while executing config command Invalid value compact_delete for configuration cleanup.policy: String must be one of: compact, delete org.apache.kafka.common.config.ConfigException: Invalid value compact_delete for configuration cleanup.policy: String must be one of: compact, delete at org.apache.kafka.common.config.ConfigDef$ValidString.ensureValid(ConfigDef.java:851) at org.apache.kafka.common.config.ConfigDef$ValidList.ensureValid(ConfigDef.java:827) at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:427) at kafka.log.LogConfig$.validate(LogConfig.scala:331) at kafka.admin.AdminUtils$.changeTopicConfig(AdminUtils.scala:524) at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:90) at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:65) at kafka.admin.ConfigCommand.main(ConfigCommand.scala) $ ./kafka-configs.sh --zookeeper <<XXXXX>>:2181 --alter --entity-type topics --entity-name ash_stream_output --add-config cleanup.policy=compact_and_delete Error while executing config command Invalid value compact_delete for configuration cleanup.policy: String must be one of: compact, delete org.apache.kafka.common.config.ConfigException: Invalid value compact_delete for configuration cleanup.policy: String must be one of: compact, delete at org.apache.kafka.common.config.ConfigDef$ValidString.ensureValid(ConfigDef.java:851) at org.apache.kafka.common.config.ConfigDef$ValidList.ensureValid(ConfigDef.java:827) at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:427) at kafka.log.LogConfig$.validate(LogConfig.scala:331) at kafka.admin.AdminUtils$.changeTopicConfig(AdminUtils.scala:524) at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:90) at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:65) at kafka.admin.ConfigCommand.main(ConfigCommand.scala) Thanks & Regards, Ashok
