[
https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haiping updated KAFKA-8161:
---------------------------
Description:
bin/kafka-configs.sh --entity-type topics --entity-name flink-mirror-test1
--zookeeper 127.0.0.1:2181/kafkat --add-config
'follower.replication.throttled.replicas=0,1:1,2' --alter
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:224)
at kafka.admin.ConfigCommand$.parseConfigsToBeAdded(ConfigCommand.scala:162)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:81)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:68)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
> Comma conflict when run script bin/kafka-configs.sh with config
> 'follower.replication.throttled.replicas'
> ----------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-8161
> URL: https://issues.apache.org/jira/browse/KAFKA-8161
> Project: Kafka
> Issue Type: Bug
> Components: admin
> Affects Versions: 0.10.2.1
> Reporter: Haiping
> Priority: Minor
>
> bin/kafka-configs.sh --entity-type topics --entity-name flink-mirror-test1
> --zookeeper 127.0.0.1:2181/kafkat --add-config
> 'follower.replication.throttled.replicas=0,1:1,2' --alter
> 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:224)
> at
> kafka.admin.ConfigCommand$.parseConfigsToBeAdded(ConfigCommand.scala:162)
> at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:81)
> at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:68)
> at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
