window
使用kafka-storage生成生成一个uuid
.\kafka-storage.bat random-uuid格式化存储
.\kafka-storage.batformat-t对应的uuid--configD:\configure\fisher\kafka\config\kraft\server.properties启动命令
.\kafka-server-start.bat D:\configure\fisher\kafka\config\kraft\server.propertieslinux
解压kafka
tar-zxvfkafka_2.13-3.8.1.tgz改文件夹名称
mvkafka_2.13-3.8.1 /data/kafka进入bin目录执行使用kafka-storage生成生成一个uuid
./kafka-storage.sh random-uuid然后去修改config/kraft/server.properties
# 表示此节点,既是broker又可以当controllerprocess.roles=broker,controller# 节点id,不重名即可node.id=1# controller竞争者,也就是controller将从它们之中诞生(这里的kafka1是刚刚设置的本机的域名解析,或者直接写localhost也行)controller.quorum.voters=1@localhost:9093listeners=PLAINTEXT://:9092,CONTROLLER://:9093# 监听地址(也就是客户端连接时访问的地址)advertised.listeners=PLAINTEXT://localhost:9092controller.listener.names=CONTROLLER# kafka数据存放地址log.dirs=data格式化存储
./kafka-storage.shformat-t对应的uuid--config/data2/kafka/config/kraft/server.properties启动命令 (守护进程启动加-daemon 参数)
./kafka-server-start.sh-daemon/data/kafka/config/kraft/server.properties问题
启动后server.log输出异常,server.properties路径有问题
[2026-05-3120:01:21,702]INFO Registered kafka:type=kafka.Log4jController MBean(kafka.utils.Log4jControllerRegistration$)[2026-05-3120:01:21,994]ERROR Exiting Kafka due to fatal exception(kafka.Kafka$)java.nio.file.NoSuchFileException: /data/kafka/config/kraft/server.properties at sun.nio.fs.UnixException.translateToIOException(UnixException.java:86)at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)at sun.nio.fs.UnixFileSystemProvider.newByteChannel(UnixFileSystemProvider.java:214)at java.nio.file.Files.newByteChannel(Files.java:361)at java.nio.file.Files.newByteChannel(Files.java:407)at java.nio.file.spi.FileSystemProvider.newInputStream(FileSystemProvider.java:384)at java.nio.file.Files.newInputStream(Files.java:152)at org.apache.kafka.common.utils.Utils.loadProps(Utils.java:653)at kafka.Kafka$.getPropsFromArgs(Kafka.scala:50)at kafka.Kafka$.main(Kafka.scala:89)at kafka.Kafka.main(Kafka.scala)