有时候我们需要快速验证一些业务功能,对kafka环境的要求没那么高,这时我们可以在开发环境,或者本地,搭建一个简单的单机版kafka。集群环境搭建点击这里
zookeeper 安装
// 解压
tar -xzvf zookeeper-3.4.14.tar.gz
cd zookeeper-3.4.14/config/
// 配置文件
cp zoo_sample.cfg zoo.cfg
// 将zookeeper添加到环境变量
vim /etc/profile
//末尾添加一行
export ZOOKEEPER_HOME=/data/zookeeper/zookeeper-3.4.14
export PATH=$PATH:$ZOOKEEPER_HOME/bin
修改完环境变量后使之生效,source /etc/profile
//启动zookeeper
zkServer.sh start
//查看zookeeper状态:
zkServer.sh status
//停止zookeeper
zkServer.sh stop
kafka安装
// 解压
tar -xvf kafka_2.12-2.0.0.tgz
// 修改kafka设置
cd kafka_2.12-2.2.0/config/
vim server.properties
log.dirs=/usr/local/kafka //这个修改的是kafka消息持久化时的保存路径。
advertised.listeners=PLAINTEXT://localhost:9092 //修改的kafka的ip:端口
//设置环境变量
vim /etc/profile
//末尾添加一行
export KAFKA_HOME=/data/kafka/kafka_2.12-2.2.0
export export PATH=$PATH:$KAFKA_HOME/bin
修改完环境变量后使之生效,source /etc/profile
//静默启动kafka
nohup ./bin/kafka-server-start.sh ./config/server.properties &
//查看9092端口:
netstat -ntlp | grep 9092
//关闭kafka
./bin/kafka-server-stop.sh
脚本
kafka启动脚本
#!/bin/sh
#启动zookeeper
zkServer.sh start
#等3秒后执行
sleep 5
#启动kafka
/data/kafka/kafka_2.12-2.2.0/bin/kafka-server-start.sh /data/kafka/kafka_2.12-2.2.0/config/server.properties &
kafka关闭脚本
#!/bin/sh
#关闭kafka
/data/kafka/kafka_2.12-2.2.0/bin/kafka-server-stop.sh
#等5秒后执行
sleep 5
#关闭zookeeper
zkServer.sh stop
网友评论