kafka搭建、學習(二)

window下Kafka安裝

1.下載最新版本 

http://kafka.apache.org/downloads

解壓後目錄結構以下(注意:解壓後的路徑中不能有空格和(x86),否則沒法啓動apache

windows文件夾中爲windows系統操縱的命令。bootstrap

2.啓動服務器

Kafka使用ZooKeeper,因此你須要先啓動一個ZooKeeper服務器,若是你尚未。 您能夠使用隨kafka一塊兒打包的便捷腳原本獲取一個快速的單節點ZooKeeper實例。windows

執行zookeeper啓動命令:bin\windows\zookeeper-server-start.bat config\zookeeper.properties服務器

新建窗口啓動Kafka服務器:bin\windows\kafka-server-start.bat config\server.propertiesspa

3.建立主題(topic)

新建窗口建立一個名稱爲「test」的主題:server

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testget

查看建立的主題:bin\windows\kafka-topics.bat --list --zookeeper localhost:2181kafka

4.建立消息提供者(producer)

建立producer:bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic testit

9092爲剛纔啓動kafka服務器端口號io

發送一條消息hello

該消息目前沒有消費者,會被暫存,有消費者後會被消息。

5.建立消息消費者(consumer)

新建窗口建立消費者:bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

能夠看見,hello已被消費。能夠繼續在producer發送消息,觀察consumer接收狀況。能夠啓多個consumer窗口觀察接收狀況。

以上爲止,單節點kafka服務已完成。

相關文章
相關標籤/搜索