本篇文章主要介紹在windows下使用vmware虛擬機器中的Linux(Centons7)下配置安裝Kafka。

簡要步驟：

①、下載Kafka解壓包

②、解壓Kafka

③、修改配置檔案

④、啟動Kafka

⑤、建立topic

詳細步驟：

一、Kafka下載

http://archive.apache.org/dist/kafka/2.0.0/

二、解壓

tar -zxvf kafka_2.11-2.0.0.tgz

三、配置

進入kafka的config目錄下，有一個server.properties，新增如下配置

kafka配置檔案說明：http://www.cnblogs.com/yinchengzhe/p/5111635.html

vim server.properties

# broker的全域性唯一編號，不能重複
broker.id=0
# 監聽
listeners=PLAINTEXT://:9092
port=9092
# 日誌目錄
log.dirs=/home/hadoop/kafka-logs
# 配置zookeeper的連線（如果不是本機，需要該為ip或主機名）
zookeeper.connect=localhost:2181

四、啟動

進入到kafka目錄

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

檢視是否成功

五、建立topic，進入bin目錄

①建立topic

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

引數說明： 

–zookeeper：指定kafka連線zk的連線url，該值和server.properties檔案中的配置項{zookeeper.connect}一樣 

–replication-factor：指定副本數量 

–partitions：指定分割槽數量 

–topic：主題名稱 

②檢視所有的topic資訊

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

③啟動生產者

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

④啟動消費者

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

./kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic test --from-beginning

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

⑤檢視消費者生產者 

⑥刪除topic

./kafka-topics.sh --delete --zookeeper localhost:2181 --topic log4jtest