一、环境准备
1、首先给linux系统配置jdk环境变量。
2、进入zookeeper官网下载安装包，并将安装包上传到linux中。
3、进入kafka官网下载安装包，并将安装包上传到linux中。
二、配置zookeeper
1、进入zookeeper安装目录中创建data和log文件夹
cd apache-zookeeper-3.6.3-bin mkdir data mkdir log
2、进入conf目录， 复制一个zoo_sample.cfg并命名为zoo.cfg
3、打开zoo.cfg加上三个配置
4、启动zookeeper
三、配置kafka
1、创建kafka-logs日志文件
2、进入对应进入目录修改配置文件
2、进入配置文件后
listeners后面改成服务器的ip地址，9092位kafka对外提供服务的默认端口
3、因为kafka需要使用zookeeper，所有需要设置zookeeper服务器的地址
4、在/etc/hosts添加一个域名，将zookeeper.connect修改为域名:端口，直接写ip地址kafka会启动失败
5、 启动kafka
进入到kafka/bin目录下
sh kafka-server-start.sh config/server.properties #这样可以后台以守护进程方式启动 sh kafka-server-start.sh -daemon config/server.properties
四、测试
1、启动kafka后使用kafka-topics.sh创建topic
./kafka-topics.sh --create --zookeeper 192.168.1.10:2181 --replication-factor 1 --partitions 1 --topic test
2、查看topic
./kafka-topics.sh --list --zookeeper 192.168.1.10:2181
3、发送消息
输入命令后会开启一个发送消息的客户端
./kafka-console-producer.sh --broker-list 192.168.1.10:9092 --topic test
4、接收消息
发送方发送一条消息，接收方就能收到
./kafka-console-consumer.sh --bootstrap-server 192.168.1.10:9092 --from-beginning --topic test
