kafka 可以不在依赖zookeeper
了,其自带了kraft
,可以替代。
安装包解压之后,在配置目录会有如下的目录:
只要在启动的时候,使用kraft
中的配置文件,就可以直接启动了,命令如下:
生成ID
KAFKA_CLUSTER_ID="$(bin/kafka-storage.sh random-uuid)"
初始化存储
bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c config/kraft/server.properties
启动
./bin/kafka-server-start.sh config/kraft/server.properties
官方文档