kafka kraft集群搭建

Kafka 2.8.0 版本移除了对Zookeeper的依赖，该版本将依赖于 ZooKeeper 的控制器改造成了基于 Kafka Raft 的 Quorm 控制器。
本文将搭建一个基于kraft机制的3个节点的kafka集群。

机器规划

机器IP	机器名	通信端口	选举端口	存储目录
192.168.4.1	kafka1	9002	9003	/data/kafka
192.168.4.2	kafka2	9002	9003	/data/kafka
192.168.4.3	kafka3	9002	9003	/data/kafka

编辑集群配置

解压kafka安装包到服务器/usr/local目录下，编辑kafka安装包文件夹中config/kraft/server.properties文件

node.id=1
controller.quorum.voters=1@192.168.4.1:9093,2@192.168.4.2:9093,3@192.168.4.3:9093
listeners=PLAINTEXT://:9092,CONTROLLER://:9093
advertised.listeners=PLAINTEXT://192.168.4.1:9092
log.dirs=/data/kafka

其他两台修改node.id即可
下面命令会生成一个唯一ID,格式化存储数据目录,执行成功后会输出format信息，其他两台按照相同id同样执行即可。

./bin/kafka-storage.sh random-uuid
./bin/kafka-storage.sh format -t M5-YscCtR2qFpBksfIOHQw -c ./config/kraft/server.properties

启动kafka

./bin/kafka-server-start.sh ./config/kraft/server.properties