标签:opt bin 启动 zookeeper kafka 0.11 安装 2.11
先启动所有机器上的zookeeper,再启动所有机器上的kafka(后台启动)(使用了xcall脚本批量运行程序)
开启zookeeper
xcall /opt/zookeeper-3.4.10/bin/zkServer.sh start
开启kakfa
xcall /opt/kafka_2.11-0.11.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-0.11.0.0/config/server.properties
关闭zookeeper
xcall /opt/zookeeper-3.4.10/bin/zkServer.sh stop
关闭kafka
xcall /opt/kafka_2.11-0.11.0.0/bin/kafka-server-stop.sh
kafka需要zookeeper单机或集群
https://kafka.apache.org/downloads
Xftp传输文件 到Linux系统中的opt文件夹
Linux安装kafka命令(Xshell)
查看文件夹有哪些文件
ls
进入opt文件夹
cd /opt
解压
tar -zxvf kafka_2.11-0.11.0.0.tgz
进入解压后的kafka文件夹
cd kafka_2.11-0.11.0.0
创建log文件夹(用于存储暂存数据,之后需要修改server.properties)
mkdir log
进入kafka的config文件夹
cd config
修改kafka服务器配置
vi server.properties
可以使用 /broker 定位内容
esc退出insert模式,使用:q退出,:wq保存并退出
这里是服务器的id,在集群中id必须唯一,创建多个kafka服务器组成集群需要修改
下面一点就是:是否能删除消息主题(把#去掉,设为能删除)
修改暂存数据目录(/opt/kafka_2.11-0.11.0.0/log)
修改为zookeeper集群
esc键 :wq保存退出
[root@hostname1 opt]# xsync kafka_2.11-0.11.0.0 hostname 2 2
其他机器
进入解压后的kafka文件夹
cd kafka_2.11-0.11.0.0
进入kafka的config文件夹
cd config
修改kafka服务器配置
vi server.properties
修改其他机器中的broker.id(必须唯一)
[root@hostname2 kafka_2.11-0.11.0.0]# bin/zookeeper-server-start.sh -daemon config/server.properties
先启动所有机器上的zookeeper,再启动所有机器上的kafka(后台启动)(使用了xcall脚本批量运行程序)
xcall /opt/zookeeper-3.4.10/bin/zkServer.sh start
xcall /opt/kafka_2.11-0.11.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-0.11.0.0/config/server.properties
也可以使用脚本运行kafka
cd /usr/local/bin
创建脚本
touch kafkastart
编辑脚本(就是将批量开启关闭zookeeper和kafka命令放入其中)
#!/bin/bash for i in hostname1 hostname2 do echo --------- $i ---------- ssh root@$i "/opt/kafka_2.11-0.11.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-0.11.0.0/config/server.properties" donekafkastart
#!/bin/bash for i in hostname1 hostname2 do echo --------- $i ---------- ssh root@$i "/opt/kafka_2.11-0.11.0.0/bin/kafka-server-stop.sh" donekafkastop
#!/bin/bash for i in hostname1 hostname2 do echo --------- $i ---------- ssh root@$i "/opt/zookeeper-3.4.10/bin/zkServer.sh start" donezkstart
#!/bin/bash for i in hostname1 hostname2 do echo --------- $i ---------- ssh root@$i "/opt/zookeeper-3.4.10/bin/zkServer.sh stop" donezkstop
添加执行权限
chmod 777 kafkastart
chmod 777 kafkastop
chmod 777 zkstart
chmod 777 zkstop
运行脚本
开启kafka
kafkastart
关闭kafka
kafkastop
开启zookeeper
zkstart
关闭zookeeper
zkstop
标签:opt,bin,启动,zookeeper,kafka,0.11,安装,2.11 来源: https://www.cnblogs.com/easyjava/p/15207631.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。