上文已經講過如何安裝Zookeeper叢集，因為Kafka叢集需要依賴Zookeeper服務，雖然Kafka有內建Zookeeper，但是還是建議獨立安裝Zookeeper叢集服務，此處不再贅述

     kafka叢集還是安裝在10.10.16.170  、 10.10.16.132  、10.10.16.133三臺機器上面

    1、kafka官網下載kafka_2.10-0.10.0.0.tgz壓縮包，解壓縮

     2、修改/appcom/kafka_2.10-0.10.0.0/config/server.properties檔案：

     10.10.16.170機器：

    broker.id=1

    host.name=CENTOS170

    listeners=PLAINTEXT://CENTOS170:9092

   advertised.listeners=PLAINTEXT://CENTOS170:9092

   log.dirs=/data/kafka-logs

   num.partitions=4

   zookeeper.connect=CENTOS170:2181,CENTOS132:2181,CENTOS133:2181

  其他配置暫時採取預設

   10.10.16.132機器：

    broker.id=2

    host.name=CENTOS132

    listeners=PLAINTEXT://CENTOS132:9092

   advertised.listeners=PLAINTEXT://CENTOS132:9092

   log.dirs=/data/kafka-logs

   num.partitions=4

   zookeeper.connect=CENTOS170:2181,CENTOS132:2181,CENTOS133:2181

  其他配置暫時採取預設

   10.10.16.132機器：

    broker.id=2

    host.name=CENTOS132

    listeners=PLAINTEXT://CENTOS132:9092

   advertised.listeners=PLAINTEXT://CENTOS132:9092

   log.dirs=/data/kafka-logs

   num.partitions=4

   zookeeper.connect=CENTOS170:2181,CENTOS132:2181,CENTOS133:2181

  其他配置暫時採取預設

   10.10.16.133機器：

    broker.id=3

    host.name=CENTOS133

    listeners=PLAINTEXT://CENTOS133:9092

   advertised.listeners=PLAINTEXT://CENTOS133:9092

   log.dirs=/data/kafka-logs

   num.partitions=4

   zookeeper.connect=CENTOS170:2181,CENTOS132:2181,CENTOS133:2181

  其他配置暫時採取預設

    3、在每臺伺服器分別啟動kafka服務：

     ./kafka-server-start.sh  /appcom/kafka_2.10-0.10.0.0/config/server.properties & （以這種方式啟動kafka應用後，kafka總會莫名其妙的退出。後來改為這種命令啟動：

         ./kafka-server-start.sh -daemon  /appcom/kafka_2.10-0.10.0.0/config/server.properties  解決了問題）

    4、任意一臺機器上面，測試：       在kafka中建立名為“cmy_nbd_topic1”的topic，該topic切分為4份，每一份備份數為3

       ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 4 --topic  cmy_nbd_topic1

    5、列出所有topic :

   ./kafka-topics.sh --list --zookeeper CENTOS170:2181,CENTOS132:2181,CENTOS133:2181