一、安裝
- kafka 需要java環境;
- kafka 最新版本內置了 zookeeper,所以不需要安裝zookeeper;
- 下載kafka最新版本,因為下載的是tgz文件,所以不需要安裝,解壓到相應的地方就可以了。下載地址:http://kafka.apache.org/downloads(我使用的版本:kafka_2.11-1.1.0)
- bin 目錄下放的是啟動kafka的文件,conf目錄下放的是kafka的各種配置文件。
? 總結:至此kafka在windows平臺上的搭建完成了。
二、使用:
? ? 簡單測試,查看是否ok。
?? ?PS:zookeeper默認端口:2181;生產者默認端口:9092
?? ?總結:
?? ??? ?簡單測試一共五步:
?? ??? ?1.啟動zookeeper
?? ??? ?2.啟動kafka
?? ??? ?3.創建主題topic
?? ??? ?4.啟動消費者 customer
?? ??? ?5.啟動生產者 producer
? ? ? ??
1.啟動zookeeper
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
2.啟動kafka
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
3.創建主題topic,并查看
創建命令:
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wzq
查看命令:
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
4.啟動消費者 customer
bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic wzq --from-beginning
5.啟動生產者 producer
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic wzq
PS:有五個黑窗口 1.zookeeper服務(不可關閉)?2.kafka服務(不可關閉) 3.創建主題(可關閉) 4.消費者(不可關閉) 5.生產者(不可關閉)。