我使用kafka 3.0.0的KRaft模式,安装kafka集群,报:
java.lang.IllegalStateException: Configured voter set: [1, 2] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
错误详情:
[2021-11-19 19:19:08,916] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IllegalStateException: Configured voter set: [1, 2] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:362)
at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:203)
at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:125)
at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:73)
at kafka.Kafka$.buildServer(Kafka.scala:79)
at kafka.Kafka$.main(Kafka.scala:87)
at kafka.Kafka.main(Kafka.scala)
我是在config/kraft/server.properties新增加了一个vote,如下:
增加前:
controller.quorum.voters=1@10.0.19.91:9093
增加后:
controller.quorum.voters=1@10.0.19.91:9093,2@10.0.19.92:9093
然后再启动的时候就报错了,我该如何解决?
新增加的投票节点{"voterId":2} 是在哪里增加啊?谢谢!
找到
config/kraft/server.properties
配置文件中的log.dirs
目录地址,删除里面的__cluster_metadata-0
目录即可。如(默认目录):
rm -rf /tmp/kraft-combined-logs/__cluster_metadata-0
然后重新运行kafka。
也可以单独删除其中的
rm -f /tmp/kraft-combined-logs/__cluster_metadata-0/quorum-state
还可以把新增加的投票节点
{"voterId":2}
手动加上去,如:{"clusterId":"","leaderId":1,"leaderEpoch":404,"votedId":-1,"appliedOffset":0,"currentVoters":[{"voterId":1},{"voterId":2}],"data_version":0}[root@m1 __cluster_m
感谢,可以启来啦。
你的答案