As described in usage description, to group the values which contain commas, we need to use square brackets.
ex: --add-config cleanup.policy=[compact,delete] On Thu, Jun 7, 2018 at 8:49 AM, Jayaraman, AshokKumar (CCI-Atlanta-CON) < ashokkumar.jayara...@cox.com> wrote: > 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 > >
