詳細安裝步驟

1. 下載kafka_2.10-0.10.0.0.tgz到/data/soft目錄

2. 進入解壓目錄(在此為/data/app/Kafka/kafka_2.10-0.10.0.0/bin)，啟動zookeeper服務。可以在命令的結尾加個&符號，這樣服務就可以在後臺執行

3. 啟動kafka服務

kafka-server-start.sh ../config/server.properties &

ps -ef | grep kafka檢視，觀察到zookeeper和kafka服務已啟動

驗證

1. 建立一個叫”test1234”的topic，它只有一個分割槽，一個副本：

kafka-topics
 
.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1234

可以用list檢視建立的topic

kafka-topics.sh --list --zookeeper localhost:2181

1. 傳送訊息。執行producer並在控制檯中輸一些訊息，這些訊息將被髮送到服務端

kafka-console-producer.sh --broker-list localhost:9092 --topic test1234

1. 在另一個終端開啟consumer，可以讀取到剛才發出的訊息並輸出。

kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1234 --from-beginning