bin/zookeeper-server-start.sh config/zookeeper.properties
1. 下載Kafka
http://archive.apache.org/dist/kafka/
2. 安裝
Kafka是使用scala編寫的運行與jvm虛擬機上的程序会通,雖然也可以在windows上使用鉴竭,但是kafka基本上是運行在linux服務器上,(也可以運行在windows上)因此我們這里也使用linux來開始今天的實戰(zhàn)。首先確保你的機器上安裝了jdk舷礼,kafka需要java運行環(huán)境姨伤,以前的kafka還需要zookeeper,新版的kafka已經(jīng)內(nèi)置了一個zookeeper環(huán)境,所以我們可以直接使用悦穿。說是安裝,如果只需要進行最簡單的嘗試的話我們只需要解壓到任意目錄即可
啟動命令:
bin/zookeeper-server-start.sh config/zookeeper.properties? ?
bin/kafka-server-start.sh config/server.properties
創(chuàng)建topic (例如創(chuàng)建topic名稱為test的topic)
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic?test
查看創(chuàng)建了哪些topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
創(chuàng)建消費者(例如創(chuàng)建為test的消費者)
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic?test?--from-beginning
創(chuàng)建生產(chǎn)者(例如test)
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic?test