一、下载软件
1.http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz
2.http://mirror.bit.edu.cn/apache/zookeeper/stable/zookeeper-3.4.13.tar.gz
二、安装zookeeper-3.4.13
1.解压
tar -xvf zookeeper-3.4.13.tar.gz
2.进入 解压目录进入
cd zookeeper-3.4.13
3. 修改配置文件 zoo.cfg .
如果没有这个文件进行 mv zoo_sample.cfg zoo.cfg
4.配置修改,修改完成并且保存。
5.启动 zookeeper
进入 bin 目录 执行 ./zkServer.sh start
三、安装kafka kafka_2.11-2.0.0
1.进行解压
tar -xvf kafka kafka_2.11-2.0.0.tar.gz
2.进行修改配置 server.properties
3.启动kafka
./kafka-server-start.sh ../config/server.properties&
四、测试kafka发送接收消息
1.发送消息
./kafka-console-producer.sh --topic Alarm --broker-list 172.17.130.222:9092
2.接收消息
./kafka-console-consumer.sh --bootstrap-server 172.17.130.222:9092 --topic Alarm --from-beginning