一、前期准备
二、kafka实验
在zookeeper后继续进行操作

2.1 为ndoe1、node2、node3作出部署
2.1.1 解压kafka压缩包(node1举例)

2.1.2 操作
将解压后的kafka移动到kafka,进入到kafka下的config中,复制文件
2.1.2.1 编辑server.properties




2.1.2.2 编辑环境变量同时运行

2.1.2.3 编辑kafka文件,同时为该文件添加权限并设置开机自启


2.2 分别为node1、node2、node3开启kafka
2.2.1 为node1开启kafka

2.2.2 为node2开启kafka

2.2.3 为node3开启kafka

2.3 node1创建topic

解释:
--zookeeper:定义zookeeper集群服务器地址,如果有多个IP地址使用逗号分割,一般使用一个IP即可
--replication-factor:定义分区副本数,1代表单副本,建议为2
--partitions:定义分区数
--topic:定义topic名称
2.4 node1查看当前所有服务器中的所有topic

2.5 node1查看某个topic的详情

2.6 node1发布消息

2.6.1 同时node2下消费消息

2.7 修改分区数


2.8 删除topic区




















