1、下载http://mirrors.shuosc.org/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

   下载http://mirror.bit.edu.cn/apache/kafka/1.1.0/kafka_2.12-1.1.0.tgz

2、新建zookeeper和kafka文件夹目录，在zookeeper目录新建zkdata、zkdataLog目录，在kafka目录新建kafkaLogs目录。将1步骤中解压后的两个文件夹分别放入zookeeper和kafka目录。

3、进入zookeeper的conf目录，将zoo_sample.cfg复制一份zoo.cfg，修改zoo.cfg：

dataDir=/home/gaofeng/zookeeper/zkdata

dataLogDir=/home/gaofeng/zookeeper/zkdataLog

4、进入kafka的config目录，修改server.properties文件。

log.dirs=/home/gaofeng/kafka/kafkaLogs

5、启动Zookeeper，如果无报错则说明启动成功。

./bin/zkServer.sh start

6、查看Zookeeper是否启动成功

./bin/zkServer.sh status

7、启动Kafka

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

8、我们可以使用jps终端命令查看是否启动（QuorumPeerMain是zookeeper服务）：

[root@bogon kafka_2.12-1.1.0]# jps

4384 Kafka

3921 QuorumPeerMain

4412 Jps

9、使用kafka

1）、创建topic：

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

2）、查看topic：　

　　./bin/kafka-topics.sh --list --zookeeper localhost:2181

3）、生产者

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

4）、消费者

　　./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

5）、删除topic

./bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

备注：[server.properties需要 设置delete.topic.enable=true]

sudo ifconfig enp2s0 10.102.7.165 netmask 255.255.255.0