只讲操作,不讲原理,不带说明。
PS:如果下面例子中给出的镜像地址不能用的话,就去官网找最新版
机器&java环境
- 准备1台centos机器
- 配置java环境
zookeeper 配置
- 创建一个你想要安装 zookeeper 的工作目录。
- 创建一个你想要保存 zookeeper 数据的工作目录。
- zookeeper 下载:
wget https://dlcdn.apache.org/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz
- zookeeper 解压:
tar -zxvf zookeeper......tar.gz
- 配置环境变量
export ZOOKEEPER_INSTALL=/home/你的zk安装路径
export PATH=$PATH:$ZOOKEEPER_INSTALL/bin
- 修改配置文件(conf目录)
- 进入conf目录:
cd zookeeper-3.3.6/conf
- 创建配置文件:
cp zoo_sample.cfg zoo.cfg
- 配置
zoo.cfg
- dataDir 改到一个单独的目录下,自己定义就好。
- 加一行配置:
server.1=本机ip地址:2888:3888
- 进入conf目录:
- 服务管理(bin目录)
- 进入bin目录:
./zkServer.sh start
启动zk。 - 查看zk服务状态:
sh zkServer.sh status
- 连接zk
- 本地:
./zkCli.sh
- 远程:
./zkCli.sh -server 你要连接的远程ip地址:端口
- 本地:
- 关闭zk:
sh bin/zkServer.sh stop
- 重启zk:
sh bin/zkServer.sh restart
- 进入bin目录:
ps:zookeeper 下载地址可以直接去官网找,记得找带 -bin 后缀的,不然会报错”找不到或无法加载主类 org.apache.zookeeper.server.quorum.QuorumPeerMain“。
kafka
- 创建一个你想要安装 kafka 的工作目录。
- 创建一个你想要保存 kafka 数据的目录和日志目录。
- kafka下载:
wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
- kafka解压:
tar -zxvf kafka......tgz
- 配置环境变量:
export KAFKA_INSTALL=/home/你的kafka安装路径
export PATH=$PATH:$KAFKA_INSTALL/bin
- 修改配置文件(config目录)
- 进入config目录:
cd config
- 修改
server.properties
文件:vim server.properties
- 把
log.dirs
改成你自己创建的日志存储目录。 - 加一行端口配置:
port=9092
- 把
- 进入config目录:
- 服务管理(bin目录)
- 前台启动kafka:
sh kafka-server-start.sh ../config/server.properties
- 后台启动kafka:
sh kafka-server-start.sh ../config/server.properties &
或./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
- 查看kafka运行状态:
jps
- 关闭kafka:
kafka-server-stop.sh
- 前台启动kafka:
- 来跑个demo(bin目录)
- 创建一个topic(名为test):
sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
- 查看 topic 列表:
sh kafka-topics.sh --list --zookeeper localhost:2181
- 创建 producer:
sh kafka-console-producer.sh --broker-list localhost:9092 --topic test
- 创建 consumer:
sh kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
- 在 producer 控制台输入消息回车发送,consumer 控制台可以查看到。
- 创建一个topic(名为test):
ps:kafka 下载地址可以去官网找,带 src 后缀的需要编译、不带 src 的不需要编译。