我执行格式化的时候报Each listener must have a different port, listeners: PLAINTEXT://:9094,CONTROLLER://:9094

识趣 发表于: 2021-11-23   最后更新时间: 2021-11-23 10:55:37   1,578 游览

我安装kafka raft集群模式的时候,报错

Exception in thread "main" java.lang.IllegalArgumentException: requirement failed: Each listener must have a different port, listeners: PLAINTEXT://:9094,CONTROLLER://:9094

我执行的是:

bin/kafka-storage.sh format -t Cba3BkapTFWyEKbpUkNJ_w -c config/kraft/server-1.properties

配置文件:

listeners=PLAINTEXT://:9094,CONTROLLER://:9094

错误明细:

Exception in thread "main" java.lang.IllegalArgumentException: requirement failed: Each listener must have a different port, listeners: PLAINTEXT://:9094,CONTROLLER://:9094
        at scala.Predef$.require(Predef.scala:337)
        at kafka.utils.CoreUtils$.validate$1(CoreUtils.scala:264)
        at kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:275)
        at kafka.server.KafkaConfig.listeners(KafkaConfig.scala:1814)
        at kafka.server.KafkaConfig.controllerListeners(KafkaConfig.scala:1820)
        at kafka.server.KafkaConfig.validateValues(KafkaConfig.scala:1945)
        at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1897)
        at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1393)
        at kafka.tools.StorageTool$.$anonfun$main$2(StorageTool.scala:62)
        at scala.Option.flatMap(Option.scala:283)
        at kafka.tools.StorageTool$.main(StorageTool.scala:62)
        at kafka.tools.StorageTool.main(StorageTool.scala)

我该如何解决?

发表于 2021-11-23

每个listener的端口不能相同:

listeners=PLAINTEXT://:9094,CONTROLLER://:9094

你写了2个相同的9094,换成不同的端口就可以了。

识趣 -> 半兽人 3年前

感谢,是我太粗心了。

你的答案

查看kafka相关的其他问题或提一个您自己的问题