'

1.Kafka服务简介及版本下载安装

1.官方版本：https://archive.apache.org/dist

2.搜索kafka_2.11-0.8.2.1.tgz版本

3.跟以往传入安装包，更改权限并解压一样

2.kafka集群配置

Server.proper

Producer proper

虚拟器端建立目录文件并复制目录

分发：

scp -r kafka_2.11-0.8.2.1/ bigdata-pro02.kfk.com:/opt/modules/

scp -r kafka_2.11-0.8.2.1/ bigdata-pro03.kfk.com:/opt/modules/

3.启动kafka依赖于zookeeper的服务并进行测试

1.先启动三台机器的zookeeper节点服务

bin/zkServer.sh start

2.bin/kafka-server-start.sh config/server.properties第一台

3.bin/kafka-topics.sh --create --zookeeper bigdata-pro01.kfk.com:2181,bigdata-pro02.kfk.com:2181,bigdata-pro03.kfk.com:2181 --replication-factor 1 --partitions 1 --topic protest第二台

4.启动zookeeper客户端

bin/zkCli.sh第三台

5.在第二台虚拟机

bin/kafka-console-producer.sh --broker-list bigdata-pro01.kfk.com:9092,bigdata-pro02.kfk.com:9092,bigdata-pro03.kfk.com:9092 --topic protest

6.克隆第二台虚拟机到新窗口

bin/kafka-console-consumer.sh --zookeeper bigdata-pro01.kfk.com:2181,bigdata-pro02.kfk.com:2181,bigdata-pro03.kfk.com:2181 --from-beginning --topic protest

7.在原来的第二台输出一些测试字段

8.克隆的第二台虚拟机就会有映射