kafka KRaft模式报:Invalid configuration value for controller.quorum.voters. Each entry should be in the form `{id}@{host}:{port}`.

啊啊 发表于: 2021-09-28   最后更新时间: 2021-09-28 16:23:20   1,419 游览

我使用kafka 3.0.0的KRaft模式,安装kafka集群,报:

ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
org.apache.kafka.common.config.ConfigException: Invalid configuration value for controller.quorum.voters. Each entry should be in the form {id}@{host}:{port}.

错误详情:

[2021-09-28 07:49:45,061] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-09-28 07:49:45,488] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
org.apache.kafka.common.config.ConfigException: Invalid configuration value for controller.quorum.voters. Each entry should be in the form `{id}@{host}:{port}`.
    at org.apache.kafka.raft.RaftConfig.parseVoterConnections(RaftConfig.java:214)
    at org.apache.kafka.raft.RaftConfig$ControllerQuorumVotersValidator.ensureValid(RaftConfig.java:270)
    at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:499)
    at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
    at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
    at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:146)
    at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1391)
    at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1394)
    at kafka.Kafka$.buildServer(Kafka.scala:67)
    at kafka.Kafka$.main(Kafka.scala:87)
    at kafka.Kafka.main(Kafka.scala)

我的server.properties配置如下:

process.roles=broker,controller
controller.quorum.voters=172.21.0.1:9092,172.21.0.1:9093,172.21.0.1:9094

请问我该如何解决?

发表于 2021-09-28
添加评论

controller.quorum.voters 的格式错了:

选民的id/endpoint信息的map列表,逗号分隔{id}@{host}:{port}。例如:1@localhost:9092,2@localhost:9093,3@localhost:9094

参考来自:Kafka Broker配置

缺少了{id}@,例如:

controller.quorum.voters=1@172.21.0.1:9092,2@172.21.0.1:9093,3@172.21.0.1:9094
你的答案

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