一、获取安装文件

本文使用的下面两个包：

• kafka_2.10-0.10.2.1.tgz
• zookeeper-3.4.5.tar.gz

可以到我的百度云下载

链接: https://pan.baidu.com/s/1bizsbRMD8I_u9xU0gEI2HA    提取码: jk88

二、安装zookeeper

由于kafka依赖于zookeeper·，所以需要先安装zookeeper

2.1  解压zookeeper·安装包并移到/usr/local/zk下

tar -zxvf zookeeper-3.4.5.tar.gz 

mv zookeeper-3.4.5 /usr/local/zk

2.2 修改zookeeper配置文件

先进入zookeeper的conf目录

cd /usr/local/zk/conf

然后复制zoo文件

cp zoo_sample.cfg zoo.cfg

之后编辑zoo.cfg文件

vim zoo.cfg

修改dataDir参数

2.3 创建data目录

mkdir data

2.4 修改环境变量

vim /etc/profile

export ZK_HOME=/usr/local/zk
export PATH=.:$ZK_HOME/bin:$PATH

修改完成后使其生效：

source /etc/profile

三、运行zookeeper

zkServer.sh start

zkServer.sh status

zkCli.sh

然后输入ls，可以看到下面截图所示：

如果你看到这些，恭喜你，zookeeper已经安装成功了！

四、安装kafka

3.1 解压kafka安装包并移到/usr/local/kafka下

tar -zxvf kafka_2.10-0.10.2.1.tgz 

mv kafka_2.10-0.10.2.1 /usr/local/kafka

3.2 修改kafka配置文件

cd /usr/local/kafka/config

vim server.properties

放开advertised.listeners的注释，ip改为服务器本机ip，修改 log.dirs参数为

/usr/local/kafka/data/kafka-logs

五、启动kafka并测试

5.1 运行kafka

bin/kafka-server-start.sh  config/server.properties  

5.2 创建kafka消息

./kafka-topics.sh --zookeeper 127.0.0.1:2181 --partitions 1 --replication-factor 1 --create --topic productscanlog

5.3 创建kafka生产者

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic productscanlog

5.4 创建kafka消费者

./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic productscanlog

 

kafka生产者发送消息，消费者同时会收到消息，至此kafka测试成功！