安裝條件：
確保zookeeper已經安裝成功。zookeeper安裝過程見：上篇，或者https://www.cnblogs.com/expiator/p/9853378.html
1.下載kafka
進入Apache官網 http://kafka.apache.org/downloads.html
選擇Binary downloads，選擇版本進行下載。
也可以直接用以下命令下載：
wget http://apache.01link.hk/kafka/2.0.0/kafka_2.11-2.0.0.tgz
2.解壓下載的kafka
cd /usr/local
tar -xzf kafka_2.11-2.0.0.tgz cd kafka_2.11-2.0.0
3. 啟動服務
3.1 啟動zookeeper
啟動zk有兩種方式，第一種是使用kafka自己帶的一個zk。
bin/zookeeper-server-start.sh config/zookeeper.properties
另一種是使用其它的zookeeper，可以位於本機也可以位於其它地址。
這種情況需要修改config下面的sercer.properties里面的zookeeper地址 。例如zookeeper.connect=192.168.213.11:2181
成功啟動zookeeper后才可以啟動kafka。
3.2 啟動 kafka
bin目錄：./kafka-server-start.sh ../config/server.properties
此命令為控制台啟動，控制台關閉即停止kafka應用
后台啟動命令:
4.創建topic （下文中localhost酌情替換為正確的zk地址或者kafka地址）
[root@bogon kafka_2.11-2.0.0]#
bin目錄下：./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
創建一個名為test的topic，只有一個副本，一個分區。
通過list命令查看剛剛創建的topic
bin目錄下
./kafka-topics.sh -list -zookeeper localhost:2181
5.啟動producer並發送消息啟動producer
[root@bogon kafka_2.11-2.0.0]#
bin目錄下
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
啟動之后就可以發送消息了
比如
test
hello boy
6.然后在另一個終端中，啟動consumer
以下是舊版本的命令：
bin目錄下：./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
報錯：consumer zookeeper is not a recognized option
發現在啟動的時候說使用 --zookeeper是一個過時的方法，最新的版本中命令如下：
bin目錄下：./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
啟動consumer之后就可以在console中看到producer發送的消息了
可以開啟兩個終端，一個發送消息，一個接受消息。
