一、前期准备
二、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名称