返回到文章

采纳

编辑于 3年前

kafka报If process.roles does not contain the 'controller' role, the node id 0 must not be included in the set of voters controller.quorum.voters=Set(0)

kafka

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

ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IllegalArgumentException: requirement failed: If process.roles does not contain the 'controller' role, the node id 0 must not be included in the set of voters controller.quorum.voters=Set(0)

错误详情:

[2021-09-28 08:02:29,085] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-09-28 08:02:29,527] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2021-09-28 08:02:29,570] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IllegalArgumentException: requirement failed: If process.roles does not contain the 'controller' role, the node id 0 must not be included in the set of voters controller.quorum.voters=Set(0)
    at scala.Predef$.require(Predef.scala:337)
    at kafka.server.KafkaConfig.validateValues(KafkaConfig.scala:1926)
    at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1897)
    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.quorum.voters=172.21.0.1:9092,172.21.0.1:9093,172.21.0.1:9094

请问我该如何解决?