本篇使用的zookeeper+kafka单机安装的版本见下文描述,软件版本不一致可能配置不尽相同,慎重参考。
不论是zookeeper还是kafka的安装都需要安装jdk环境,不再赘述
zookeeper的安装
下载zookeeper(本篇使用3.4.14版本)
# wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
解压
# tar -zxvf zookeeper-3.4.14.tar.gz
改解压文件夹名字为zookeeper,方便本文的描述
# mv zookeeper-3.4.14 zookeeper
进入zookeeper文件夹的conf文件夹,复制一份配置文件为zoo.cfg
# cd zookeeper/conf/
# cp zoo_sample.cfg zoo.cfg
本文是单机zookeeper不配置集群,所以不用修改任何配置,默认的2181端口和其他默认配置即可
启动zookeeper,启动脚本在bin目录下,脚本名是zkServer.sh
# cd ../
# bin/zkServer.sh start
kafka安装
下载kafka(本篇使用2.11-0.10.2.0版本)
# wget https://archive.apache.org/dist/kafka/0.10.2.2/kafka_2.12-0.10.2.2.tgz
解压
# tar -zxvf kafka_2.11-0.10.2.0.tgz
改解压文件夹名字为kafka,方便本文的描述
# mv kafka_2.11-0.10.2.0 kafka
修改配置文件(其他默认配置不用动),这里主要是配置了外网访问
broker.id=0
#打开listeners的注释,改为:
listeners=PLAINTEXT://0.0.0.0:9092
#打开advertised.listeners的注释,改为,本机公网ip是106.12.77.102
advertised.listeners=PLAINTEXT://106.12.77.102:9092
#zookeeper连接端口
zookeeper.connect=192.168.0.4:2181
启动kafka,启动脚本是bin目录下的kafka-server-start.sh,在kafka目录下运行启动(-daemon表示在后台启动,如果查看进程没有启动成功,可以先去掉启动看看启动日志排错)
# bin/kafka-server-start.sh -daemon config/server.properties