kafka使用kraft

window

使用kafka-storage生成生成一个uuid

.\kafka-storage.bat random-uuid

格式化存储

在这里插入代码片

.\kafka-storage.bat format -t 对应的uuid D:\configure\fisher\kafka\config\kraft\server.properties

启动命令

.\kafka-server-start.bat D:\configure\fisher\kafka\config\kraft\server.properties

linux

解压kafka

tar -zxvf kafka_2.13-3.8.1.tgz

改文件夹名称

mv kafka_2.13-3.8.1 /data/kafka

进入bin目录执行使用kafka-storage生成生成一个uuid

./kafka-storage.sh random-uuid

然后去修改config/kraft/server.properties

# 表示此节点，既是broker又可以当controller
process.roles=broker,controller
# 节点id，不重名即可
node.id=1
# controller竞争者，也就是controller将从它们之中诞生(这里的kafka1是刚刚设置的本机的域名解析，或者直接写localhost也行)
controller.quorum.voters=1@localhost:9093
listeners=PLAINTEXT://:9092,CONTROLLER://:9093
# 监听地址(也就是客户端连接时访问的地址)
advertised.listeners=PLAINTEXT://localhost:9092
controller.listener.names=CONTROLLER
# kafka数据存放地址
log.dirs=data

格式化存储

./kafka-storage.sh format -t 对应的uuid /data/kafka/config/kraft/server.properties

启动命令 (守护进程启动加-daemon 参数)

./kafka-server-start.sh -daemon /data/kafka/config/kraft/server.properties