一、安装

        Kafka依赖于ZooKeeper，所以在安装Kafka之前请确保ZooKeeper集群已安装正确并能正常运行。虽然Kafka自身内置了ZooKeeper，但是还是建议大家单独部署ZooKeeper集群，因为可能其他框架也需要使用ZooKeeper。

        （一）、Kafka下载地址：http://mirrors.hust.edu.cn/apache/kafka/，你可以选择你需要的版本，如下：

        我选择的是Kafka0.9.0.1版本，如下：

        （二）Kafka安装步骤

        1、解压

        执行tar命令，如下：

        解压后目录如下：

        其中，bin目录如下：

        config目录如下：

        2、修改参数配置

        编辑config/server.properties文件，如下：

        修改的参数包括：

        2.1、ZooKeeper连接地址：zookeeper.connect

        2.2、Broker的ID：broker.id（每个Broker保持唯一，可从0开始递增编号）

        2.3、主机名：host.name

        2.4、分区数目：num.partitions

        2.5、日志地址：log.dirs

        3、启动

        执行命令：JMS_PORT=9998 bin/kafka-server-start.sh config/server.properties & 

        4、停止

        执行停止命令bin/kafka-server-stop.sh报错，如下：

        所以，我们不得不通过直接kill进程的命令来停止Kafka，如下：

        先查找进程号

        再直接kill

        二、验证测试

        进入kafka根目录

        1、创建topic

        bin/kafka-topics.sh -zookeeper server3:2181 -topic testtopic -replication-factor 2 -partitions 5 -create

        2、查看topic

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

        其中，test为之前所创建的topic，已被删除，所以后面标注为：marked for deletion

        3、创建producer

        bin/kafka-console-producer.sh -broker-list server2:9092,server3:9092 -topic testtopic

        4、创建consumer

        bin/kafka-console-consumer.sh -zookeeper server3:2181 - from-begining -topic testtopic

        5、producer发布

        6、consumer订阅

        可以看到，producer发布了三条消息，分别为"wo shi zhong guo ren"、"dududu"、"hahaha"，而consumer收到了三条一样的消息，验证测试完毕，Kafka已正确安装并成功运行！