Chia-Ping Tsai created KAFKA-17525:
--------------------------------------
Summary: Convert the UnknownServerException to
InvalidRequestException when altering client-metrics config at runtime
Key: KAFKA-17525
URL: https://issues.apache.org/jira/browse/KAFKA-17525
Project: Kafka
Issue Type: Improvement
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
see following test:
{code:bash}
chia7712@fedora:~/project/kafka$ bin/kafka-configs.sh --bootstrap-server
192.168.1.149:22222 --alter --entity-type client-metrics --entity-name test
--add-config interval.ms=bbb
Error while executing config command with args '--bootstrap-server
192.168.1.149:22222 --alter --entity-type client-metrics --entity-name test
--add-config interval.ms=bbb'
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.UnknownServerException: The server experienced
an unexpected error when processing the request.
at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:180)
at
kafka.admin.ConfigCommand$.alterResourceConfig(ConfigCommand.scala:581)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:449)
at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:351)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:100)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
Caused by: org.apache.kafka.common.errors.UnknownServerException: The server
experienced an unexpected error when processing the request.
{code}
By contrast, `topic` resource can handle the such error and then return
`InvalidRequestException`
```bash
chia7712@fedora:~/project/kafka$ bin/kafka-configs.sh --bootstrap-server
192.168.1.149:22222 --alter --topic chia --add-config flush.ms=aaa
Error while executing config command with args '--bootstrap-server
192.168.1.149:22222 --alter --topic chia --add-config flush.ms=aaa'
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.InvalidConfigurationException: Invalid value aaa
for configuration flush.ms: Not a number of type LONG
at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:180)
at
kafka.admin.ConfigCommand$.alterResourceConfig(ConfigCommand.scala:581)
at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:371)
at kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:351)
at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:100)
at kafka.admin.ConfigCommand.main(ConfigCommand.scala)
Caused by: org.apache.kafka.common.errors.InvalidConfigurationException:
Invalid value aaa for configuration flush.ms: Not a number of type LONG
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)