kafka与zookeeper常用命令和知识点

Posted 2023-03-03 苦荞米

zookeeper

启动ZK服务：bin/zkServer.sh start
查看ZK服务状态：bin/zkServer.sh status
停止ZK服务：bin/zkServer.sh stop
重启ZK服务：bin/zkServer.sh restart
连接服务器：zkCli.sh -server 192.168.10.11:2181

查看节点：ls [path] path为节点路径
创建节点信息：create [-s] [-e] path data 其中-s 为有序节点 -e临时节点 默认为持久化节点
查看节点信息：get [path]
删除节点：delete path [dataVersion]

get命令详解：

[zk: 192.168.9.5:2181(CONNECTED) 1] get /kafka
null（节点内容）
cZxid = 0x2（创建的事务id）
ctime = Tue Aug 07 15:07:00 CST 2018（创建时间）
mZxid = 0x2（最后一次修改的事务id）
mtime = Tue Aug 07 15:07:00 CST 2018（修改时间）
pZxid = 0x1c00457（子节点最后一次修改的事物id）
cversion = 222（子节点修改次数）
dataVersion = 0（子节点数据修改次数）
aclVersion = 0
ephemeralOwner = 0x0（如果为临时节点 则为创建该节点的绘画SessingId 持久化节点则显示0x0）
dataLength = 0（数据内容长度）
numChildren = 10（当前节点的下一级节点数量）

kafka

kafka集群分为两类机器，一类为kafka(集群)，存储队列数据，一类为zk(集群)，存储集群信息。
生产者一般接连接kafka服务即可(有时也叫Broker 经纪人)，单向联系，无需在zk中注册。
消费者一般接连接zk服务，注册成为消费者(具体看使用的连接依赖包)。

配置文件路径：kafka服务文件夹/config/server.properties
其中zookeeper.connect配置项为kafka连接的zk服务器(后面可以添加路径以指定集群信息存储到某一路径下)。

kafka在zk服务中创建的路
其中路径/brokers/ids/*中存储了所有kafka服务器的地址和端口信息，可以通过get命令获取。

查看kafka版本，可以查看kafka服务文件夹/libs下面的文件，其中有类似kafka_2.12-2.0.0.jar的文件。
2.12代表实行该kafka的Scala语言版本，后面的2.0.0代表Kafka服务版本。注意，当使用java连接时，使用的jar包一定要版本一致。