[
https://issues.apache.org/jira/browse/KAFKA-9942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9942:
-
Description:
{quote}$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter
--add-config producer_byte_rate=10,consumer_byte_rate=10
--entity-type clients --entity-default
{quote}
This usage of --entity-default with --bootstrap-server for alternating configs
will trigger the exception below.
{quote}java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.UnknownServerException: Path must not end with /
character
at
org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at
org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at
org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:104)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:272)
at kafka.admin.ConfigCommand$.getAllClientQuotasConfigs(ConfigCommand.scala:501)
at kafka.admin.ConfigCommand$.getClientQuotasConfig(ConfigCommand.scala:487)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:361)
at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:292)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:91)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
Caused by: org.apache.kafka.common.errors.UnknownServerException: Path must not
end with / character
{quote}
However, if the --entity-type is brokers, the alternation works fine.
{quote}# No exception, works properly
bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type brokers
--entity-default --alter --add-config unclean.leader.election.enable=true
{quote}
was:
$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --add-config
producer_byte_rate=10,consumer_byte_rate=10 --entity-type
clients --entity-default
The command above will trigger the exception below
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.UnknownServerException: Path must not end with /
character
at
org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at
org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at
org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:104)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:272)
at kafka.admin.ConfigCommand$.getAllClientQuotasConfigs(ConfigCommand.scala:501)
at kafka.admin.ConfigCommand$.getClientQuotasConfig(ConfigCommand.scala:487)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:361)
at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:292)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:91)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
Caused by: org.apache.kafka.common.errors.UnknownServerException: Path must not
end with / character
> --entity-default flag is not working for alternating configs in AdminClient
> ---
>
> Key: KAFKA-9942
> URL: https://issues.apache.org/jira/browse/KAFKA-9942
> Project: Kafka
> Issue Type: Bug
>Reporter: Cheng Tan
>Assignee: Cheng Tan
>Priority: Major
>
> {quote}$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter
> --add-config producer_byte_rate=10,consumer_byte_rate=10
> --entity-type clients --entity-default
> {quote}
> This usage of --entity-default with --bootstrap-server for alternating
> configs will trigger the exception below.
>
> {quote}java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.UnknownServerException: Path must not end with
> / character
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
> at
> org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:104)
> at
> org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:272)
> at
> kafka.admin.ConfigCommand$.getAllClientQuotasConfigs(ConfigCommand.scala:501)
> at kafka.admin.ConfigCommand$.getClientQuotasConfig(ConfigCommand.scala:487)
> at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:361)
> at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:292)
> at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:91)
> at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
> Caused by: org.apache.kafka.common.errors.UnknownServerException: Path must
> not end with / character
> {quote}
> However, if the --entity-type is brokers, the alternation works fine.
> {quote}#
