You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Cheng Tan (Jira)" <ji...@apache.org> on 2020/04/30 03:45:00 UTC
[jira] [Updated] (KAFKA-9942) --entity-default flag is not working for alternating configs in AdminClient

     [ https://issues.apache.org/jira/browse/KAFKA-9942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Cheng Tan updated KAFKA-9942:
-----------------------------
    Description: 
$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --add-config producer_byte_rate=1000000000,consumer_byte_rate=1000000000 --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

  was:
$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --add-config producer_byte_rate=1000000000,consumer_byte_rate=1000000000 --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
>            Priority: Major
>
> $ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --add-config producer_byte_rate=1000000000,consumer_byte_rate=1000000000 --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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)