1:运行kafka需要依赖jdk环境所以我们这里先安装jdk环境,我这里采用apt方式安装,这样安装完不需要手动配置jdk环境变量比较便捷
sudo apt-get update #更新源
sudo apt-get install openjdk-8-jdk #安装jdk环境
java -version #测试jdk是否安装成功
2:添加host ip映射到/etc/hosts,同时填写你的本机ip
sudo vi /etc/hosts #将你的ip地址填进去 kafka 192.168.X.X
3:下载安装kafka
wget http://mirrors.shuosc.org/apache/kafka/1.0.0/kafka_2.11-1.0.0.tgz #下载kafka
tar -zxvf kafka_2.11-1.0.0.tgz #解压文件
4:进入kafka_2.11-1.0.0/config/配置文件目录复制3个配置文件并修改
cd kafka_2.11-1.0.0/config #进入kafka配置文件目录
cp server.properties server0.properties #复制出三个配置文件
cp server.properties server1.properties
cp server.properties server2.properties
server0.properties #以下是server0.properties 里面的配置信息修改
broker.id=0
port=9092
host.name=kafka
advertised.host.name=192.168.126.91
log.dirs=/tmp/kafka-logs_00
server1.properties #以下是server1.properties 里面的配置信息修改
broker.id=1
port=9093
host.name=kafka
advertised.host.name=192.168.126.91
log.dirs=/tmp/kafka-logs_01
server2.properties #以下是server2.properties 里面的配置信息修改
broker.id=2
port=9094
host.name=kafka
advertised.host.name=192.168.126.91
log.dirs=/tmp/kafka-logs_02
5:下载zookeeper并安装
http://mirrors.hust.edu.cn/apache/zookeeper/ #zookeeper下载地址 你去哪下载都行
sudo tar -zxvf zookeeper-3.4.6.tar.gz #解压文件
6:将zookeeper中的配置文件原始为zoo_sample.cfg 更改为zoo.cfg
cd /zookeeper-3.4.6/conf #进入zookeeper配置目录
sudo cp -v zoo_sample.cfg zoo.cfg #复制zoo_sample.cfg到zoo.cfg
7:启动zookeeper和kafka
cd ./zookeeper-3.4.6/bin #进入到zookeeper的bin目录
sudo ./zkServer.sh start #执行启动命令
cd ../../kafka_2.11-0.10.0.1/bin #进入到kafka的bin目录
./kafka-server-start.sh ../config/server0.properties & #分别执行我们的设置的那3个配置文件
./kafka-server-start.sh ../config/server1.properties &
./kafka-server-start.sh ../config/server2.properties &
8:检查kafka是否启动成功
netstat -an | grep 909 #9092 9093 9094三个端口均处在listening状态,如果某个端口未关闭,则需要重新启动控制端口为该端口的kafka进程