Patrik Kleindl created KAFKA-7281:
-------------------------------------
Summary: Fix documentation and error message regarding
cleanup.policy=[compact,delete]
Key: KAFKA-7281
URL: https://issues.apache.org/jira/browse/KAFKA-7281
Project: Kafka
Issue Type: Task
Components: config
Affects Versions: 1.1.0
Reporter: Patrik Kleindl
Issue as requested in:
https://lists.apache.org/thread.html/621821e321b9ae5a8af623f5918edc4ceee564e0561009317fc705af@%3Cusers.kafka.apache.org%3E
1) The documentation at [https://kafka.apache.org/documentation/] is missing
the updated information regarding the "compact,delete" cleanup policy on topic
level.
log.cleanup.policy on broker level
The default cleanup policy for segments beyond the retention window. A comma
separated list of valid policies. Valid policies are: "delete" and "compact"
cleanup.policy on topic level
A string that is either "delete" or "compact".
2) Also the special notation for the command-line client should be noted:
./kafka-configs --zookeeper broker0:2181 --alter --entity-type topics
--entity-name test --add-config cleanup.policy=[compact,delete]
Completed Updating config for entity: topic 'test'.
3) The config command does not show this new notation in the error message:
./kafka-configs --zookeeper broker0:2181 --alter --entity-type topics
--entity-name test --add-config cleanup.policy=test
Error while executing config command with args '--zookeeper broker0:2181
--alter --entity-type topics --entity-name test --add-config
cleanup.policy=test'
org.apache.kafka.common.config.ConfigException: Invalid value test for
configuration cleanup.policy: String must be one of: compact, delete
at
org.apache.kafka.common.config.ConfigDef$ValidString.ensureValid(ConfigDef.java:930)
at
org.apache.kafka.common.config.ConfigDef$ValidList.ensureValid(ConfigDef.java:906)
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:478)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:462)
at kafka.log.LogConfig$.validate(LogConfig.scala:299)
at kafka.zk.AdminZkClient.validateTopicConfig(AdminZkClient.scala:336)
at kafka.zk.AdminZkClient.changeTopicConfig(AdminZkClient.scala:348)
at kafka.zk.AdminZkClient.changeConfigs(AdminZkClient.scala:285)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:133)
at kafka.admin.ConfigCommand$.processCommandWithZk(ConfigCommand.scala:100)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:77)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
