【发布时间】:2022-01-12 07:30:24
【问题描述】:
当尝试更改 docker 容器 kafka 主题retention.ms(以清除它)时,我遇到了这个错误:
使用 args '--bootstrap-server localhost:9092 --entity-type topics --alter --entity-name 执行配置命令时出错 history.data_state_change --add-config 保留.ms=1000' java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.UnsupportedVersionException:代理 不支持 INCREMENTAL_ALTER_CONFIGS 在 java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) 在 java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096) 在 org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:180) 在 kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:360) 在 kafka.admin.ConfigCommand$.processCommand(ConfigCommand.scala:327) 在 kafka.admin.ConfigCommand$.main(ConfigCommand.scala:98) 在 kafka.admin.ConfigCommand.main(ConfigCommand.scala) 引起:org.apache.kafka.common.errors.UnsupportedVersionException:代理 不支持 INCREMENTAL_ALTER_CONFIGS
我正在运行的命令是:
kafka-configs --bootstrap-server localhost:9092 --entity-type 主题 --alter --entity-name history.data_state_change --add-config retention.ms=1000
我不确定这是什么 INCREMENTAL_ALTER_CONFIGS 以及如何添加它,有人可以在这里分享一些智慧吗?
【问题讨论】:
-
错误是不言自明的。您应该显示您正在运行的 docker 映像;你不“添加”它;你升级经纪人
标签: docker apache-kafka kafka-topic