kafka3.6.1版本学习

kafka目录结构

bin linux系统下可执行脚本文件
bin/windows windows系统下可执行脚本文件
config 配置文件
libs 依赖类库
licenses 许可信息
site-docs 文档
logs 服务日志

启动ZooKeeper

进入Kafka解压缩文件夹的config目录，修改zookeeper.properties配置文件
#the directory where the snapshot is stored.
#修改dataDir配置，用于设置ZooKeeper数据存储位置，该路径如果不存在会自动创建。
dataDir=E:/kafka_2.12-3.6.1/data/zk

打开DOS窗口

#因为当前目录为windows，所以需要通过相对路径找到zookeeper的配置文件。
zookeeper-server-start.bat …/…/config/zookeeper.properties

出现如下界面，ZooKeeper启动成功

为了操作方便，也可以在kafka解压缩后的目录中，创建脚本文件zk.cmd。

#调用启动命令，且同时指定配置文件。
call bin/windows/zookeeper-server-start.bat config/zookeeper.properties

启动Kafka

进入Kafka解压缩文件夹的config目录，修改server.properties配置文件

#Listener name, hostname and port the broker will advertise to clients.
#If not set, it uses the value for “listeners”.
#客户端访问Kafka服务器时，默认连接的服务为本机的端口9092，如果想要改变，可以修改如下配置
#此处我们不做任何改变，默认即可
#advertised.listeners=PLAINTEXT://your.host.name:9092
#A comma separated list of directories under which to store log files
#配置Kafka数据的存放位置，如果文件目录不存在，会自动生成。
log.dirs=E:/kafka_2.12-3.6.1/data/kafka

打开DOS窗口, 进入kafka/bin/windows目录
调用启动指令，传递配置文件的路径

#因为当前目录为windows，所以需要通过相对路径找到kafka的配置文件。
kafka-server-start.bat …/…/config/server.properties

出现如下界面，Kafka启动成功。

为了操作方便，也可以在kafka解压缩后的目录中，创建脚本文件kfk.cmd。

#调用启动命令，且同时指定配置文件。
call bin/windows/kafka-server-start.bat config/server.properties

DOS窗口中，输入jps指令，查看当前启动的软件进程

这里名称为QuorumPeerMain的就是ZooKeeper软件进程，名称为Kafka的就是Kafka系统进程。此时，说明Kafka已经可以正常使用了。