配置環(huán)境: 首先安裝kafka(新版自帶zookeeper),由于自己在安裝時(shí)按照老版教程先將zookeeper安裝好了,所以還要配置zookeeper的環(huán)境變量. 在配置zookeeper的環(huán)境變量的時(shí)候,發(fā)現(xiàn)配置在系統(tǒng)變量中無效,所以又在用戶變量中配置一遍.

啟動(dòng)zookeeper :? 在D:\soft\kafka_2.11-2.0.1中? 輸入命令?

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

(使用kafka中自帶的zookeeper , 單獨(dú)安裝的zookeeper無效(Windows中))

啟動(dòng)kafka :進(jìn)入kafka安裝目錄D:\soft\kafka_2.11-2.0.1后輸入命令

.\bin\windows\kafka-server-start.bat .\config\server.properties

創(chuàng)建主題 :D:\soft\kafka_2.11-2.0.1\bin\windows? ? 輸入命令?

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test0811

>

{"code":null,"type":3,"deviceId":19895,"payCode":"134663773503974934","ticketId":6,"count":1}

創(chuàng)建生產(chǎn)者 :? D:\soft\kafka_2.11-2.0.1\bin\windows? 輸入命令? ?

kafka-console-producer.bat --broker-list localhost:9092 --topic test0811?

生產(chǎn)者創(chuàng)建后不要關(guān)閉

啟動(dòng)消費(fèi)者 :? D:\soft\kafka_2.11-2.0.1\bin\windows? 輸入命令?

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test0811 --from-beginning

過時(shí)的啟動(dòng)命令( kafka-console-consumer.bat --zookeeper localhost:2181 --topic test0811)

在producer命令行窗口中任意輸入內(nèi)容，回車? 在consumer命令行窗口中即可看到相應(yīng)的內(nèi)容。

將storm下載解壓后配置環(huán)境變量

打開三個(gè)命令窗口分別運(yùn)行 Nimbus , Supervisor , UI Daemons

命令 :