在root的用户下

1）：前提 安装JDK环境，设置JAVA环境变量

2）：下载kafka，命令：wget  http://mirrors.shuosc.org/apache/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz

3）：下载zookeeper，命令：wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

4）：然后去解压zookeeper包，我把zookeeper-3.4.10文件夹名称改为了zookeeper ，首先找到conf的文件夹，然后备份一份zoo_sample.cfg文件 ，备份名为zoo.cfg

 命令:cp zoo_sample.cfg  zoo.cfg

5）：打开zoo.cfg的文件

     命  令 ：vim zoo.cfg   

dataDir=/tmp/zookeeper  (虽然给出这个路径给你，但是系统并没有，要你自己创建的，你可以不按这个路径)

dataLogDir=/tmp/zookeeperlog （这是我另外夹的用来存放日志文件）

6）：启动 zookeeper 

root@debian8:/usr/local/zookeeper# 命令 ：     bin/zkServer.sh start 

 

7）解压kafka的包，我把kafka_2.10-0.10.2.1文件夹名称改为了kafka，到config路径下找到 server.properties  

  找到log.dirs=/tmp/kafka-logs （跟刚刚zookeper一样创建） 

        listeners（所在机器ip地址）我这里是本地，不管它

8）：启动kafka

命令：nohup bin/kafka-server-start.sh config/server.properties &

 运行之后不管成功否它都会在你的kafka包下生成一个 nohup.out的文件

9）： 查看是否成功了

新建一个topic

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

查看 topic是否成功

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

10）：把kafka的生产者启动来 

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

11）：另开一个终端（创建新的），把消费者启动起来： 

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

 

12）：在生产者终端输入数据，消费者马上就会消费显示出来

 

生产者：

消费者：