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