解壓後目錄結構以下(注意:解壓後的路徑中不能有空格和(x86),否則沒法啓動)apache
windows文件夾中爲windows系統操縱的命令。bootstrap
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
新建窗口建立一個名稱爲「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
建立producer:bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic testit
9092爲剛纔啓動kafka服務器端口號io
發送一條消息hello
該消息目前沒有消費者,會被暫存,有消費者後會被消息。
新建窗口建立消費者:bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
能夠看見,hello已被消費。能夠繼續在producer發送消息,觀察consumer接收狀況。能夠啓多個consumer窗口觀察接收狀況。
以上爲止,單節點kafka服務已完成。