安裝條件：

確保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

4.創建topic

[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發送的消息了

可以開啟兩個終端，一個發送消息，一個接受消息。

參考資料：https://blog.csdn.net/aitcax/article/details/49583351

linux下安裝kafka