一、单机版kafka的安装
1、下载kafka的安装包并解压
tar -txvf kafka_2.11-0.9.0.1.tgz -C path(需要解压到的路径)
2、配置环境变量
2.1、vi ~/.bash_profile
2.2、添加:
KAFKA_HOME=/opt/kafka_2.11-0.9.0.1
PATH=$PATH:$KAFKA_HOME/bin
2.3、一定要source
source ~/.bash_profile
3、修改配置文件
3.1、进入编辑模式
cd /opt/kafka_2.11-0.9.0.1/config
vi server.properties
3.2、添加
broker.id=0 //为依次增长的:0、1、2、3、4,集群中唯一id
log.dirs=/opt/kafka_2.11-0.9.0.1/logs //日志地址
zookeeper.connect=master:2181,slave1:2181,slave2:2181 //zookeeperServers列表,各节点以逗号分开
4、启动程序
先要确保zookeeper已启动,然后在Kafka目录执行
nohup bin/kafka-server-start.sh config/server.properties&
如果无报错则说明启动成功。nohup &是实现在后台启动。
二、单机版zookeeper的安装
1、上传并解压zookeeper的安装包
tar -zxvf zookeeper-3.4.6.tar.gz -C path(要解压到的路径)
2、重命名配置文件
使用“cd zookeeper-3.4.6/conf"命令切换到conf目录下,
使用"mv zoo_sample.cfg zoo.cfg "命令重命名 zoo.cfg
3、修改配置文件
根据需求使用vi编辑器修改zoo.cfg配置文件,修改后保存:
tickTime: zookeeper中使用的基本时间单位, 毫秒值
dataDir: 数据目录. 可以是任意目录
dataLogDir: log目录, 同样可以是任意目录. 如果没有设置该参数, 将使用和dataDir相同的设置
clientPort: 监听client连接的端口号
4、启动zookeeper
zookeeper/bin/zkServer.sh start
5、查看zookeeper状态
zookeeper/bin/zkServer.sh status
6、停止zookeeper
zookeeper/bin/zkServer.sh stop
7、链接zookeeper的客户端
bin/zkCli.sh -server IP:port