1. 安装

kafka安装包可以通过官网下载：https://kafka.apache.org/downloads

本次案例使用 kafka_2.11-1.0.0.tgz，

把软件上传或下载到/opt/ 目录下

2.解压缩

tar -zxvf kafka_2.11-1.0.0.tgz

3.启动\关闭Zookeeper

当前下载的kafka程序里自带Zookeeper，可以直接使用其自带的Zookeeper，也可以单独使用Zookeeper安装文件。

3.1启动

./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties

加-daemon参数，可以在后台启动Zookeeper

3.2 关闭

./bin/zookeeper-server-stop.sh -daemon ./config/zookeeper.properties

4.kafka配置和启动

4.1配置

kafka的配置文件在config/server.properties文件中，主要修改参数如下，更具体的参数说明以后再整理下。

broker.id是kafka broker的编号，集群里每个broker的id需不同

4.2启动

cd /opt/kafka_2.11-1.0.0/bin
./kafka-server-start.sh -daemon ../config/server.properties

4.3 创建主题topic

./kafka-topics.sh --create --zookeeper 192.168.224.111:2181 --partitions 1 --replication-factor 1 --topic test

4.4 启动生产者

./kafka-console-producer.sh --broker-list 192.168.224.111:9092 --topic test

4.5 .启动消费者

./kafka-console-consumer.sh --bootstrap-server 192.168.224.111:9092 --topic test --from-beginning