代理不支持INCREMENTAL_ALTER_CONFIGS



当试图更改docker容器kafka主题保留.ms(为了清除它(时,我遇到了以下错误:

使用args执行config命令时出错--引导服务器localhost:9092--实体类型主题--alter--实体名称history.data_state_change--添加配置保留。ms=1000'java.util.concurrent.ExecutionException:org.apache.kafka.commun.errors.UnsupportedVersionException:代理不支持INCREMENTAL_ALTER_CONFIGS位于java.base/java.util.concurrent.CompleteFuture.reportGet(CompleteFuture.java:396(位于java.base/java.util.concurrent.CompleteFuture.get(CompleteFuture.java:2096(网址:org.apache.kafka.common.internals.CafkaFutureImpl.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.commun.errors.UnsupportedVersionException引起:broker不支持INCREMENTAL_ALTER_CONFIGS

我运行的命令是:

kafka configs--引导服务器localhost:9092--实体类型主题--alter--实体名称历史.data_state_change--添加配置保留。ms=1000

我不确定这个INCREMENTAL_ALTER_CONFIGS是什么,我该如何添加它,有人能在这里分享一些智慧吗?

根据OneCricketer的建议,我将卡夫卡图像从IMAGE_KAFKA := wurstmeister/kafka:2.11-2.0.0更改为IMAGE_KAFKA := wurstmeister/kafka:2.13-2.7.1,这就成功了。

最新更新