Kafka系列（五）Kraft模式

菜单

一、使用Kraf模式

一、使用Kraf模式

Kafka已经在2.8版本可以弃用Zookeeper启动Kraft模式

1.1修改配置文件

shell>cd /data/app/kafka/kraft
shell>vim server.properties

例如之前zookeeper的broker节点如下

hadoop102:broker.id=0
hadoop103:broker.id=1
hadoop104:broker.id=2

现在以hadoop102为例子

###1、设置node.id
node.id=0
###2、修改controller.quorum.voter
controller.quorum.voter=0@hadoop102:9093,1@hadoop103:9093,2@hadoop104:9093
###3、设置当前主机advertised.listeners
advertised.listeners=PLAINTEXT://haddop102:9092
####4、修改Kafka存储日志的位置
log.dirs=/data/app/kafka/data

1.2分发到其他节点

切记修改：server.properties

修改node.id和第3点advertised.listeners

1.3初始化集群

shell>cd /data/app/kafka
shell>bin/kafka-storage.sh random-uuid

执行后获得一串uuid字符串

1.4 使用uuid格式化Kafka的存储目录

shell>cd /data/app/kafka
shell>bin/kafka-storage.sh format -t ***（上一步得到的字符串）

1.5启动Kafka集群

shell>cd /data/app/kafka
shell>bin/kafka-server-start.sh -daemon config/kraft/server.properties

打赏赞