kafka 以windows服務的方式在windows下安裝並自啟動

准備工作：

 

　　下載kafka

　　　　http://apache.fayea.com/kafka/0.10.0.0/kafka_2.10-0.10.0.0.tgz

　　　　解壓kafka至D:\bigdata\kafka_2.10-0.10.0.0

　　
　　下載instsrv.exe /srvany.exe

　　　　將instsrv.exe /srvany.exe 拷貝至 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

 

1.注冊服務

　　以管理員身份打開cmd

　　cd D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

　　instsrv KafkaService D:\bigdata\kafka_2.10-0.10.0.0\bin\windows\srvany.exe

　　卸載服務：instsrv KafkaService remove 或 sc delete KafkaService

 

2.編輯注冊表

　　cmd ==> regedit

　　定位到以下路徑：HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\KafkaService

　　如果該服務名下沒有Parameters項目，則對服務名稱項目右擊新建項，名稱為Parameters，

　　定位到Parameters項，新建以下幾個字符串值：

　　　　a.名稱 Application 值為你要作為服務運行的BAT文件地址：D:\bigdata\kafka_2.10-0.10.0.0\bin\windows\kafka-server-start.bat

　　　　b.名稱 AppDirectory 值為你要作為服務運行的BAT文件所在文件夾路徑：D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

　　　　c.名稱 AppParameters 值為你要作為服務運行的BAT文件啟動所需要的參數：D:\bigdata\kafka_2.10-0.10.0.0\config\server.properties

3.啟動服務即可。

4.測試kafka

　　參考地址：http://www.open-open.com/lib/view/open1453179304245.html

　　1).生成 Kafka 的 Topic

　　　　打開一個命令行窗口，進入到目錄 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

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

　　2).生成生產者

　　　　打開一個命令行窗口，進入到目錄 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

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

　　3).生成消費者

　　　　打開一個命令行窗口，進入到目錄 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

　　　　kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

　　在生產者命令行窗口內隨便輸入一段字符，然后回車，你應該能看到同樣的消息出現在消費者的命令行窗口內

　　如果在消費者端能看到你推送的消息，那么你已經成功的安裝了Kafka

5.kafka監控

　　1.Apache Kafka監控之KafkaOffsetMonitor

　　2.Apache Kafka監控之Kafka Web Console

 

參考網址：

http://damacheng009.iteye.com/blog/2087916?utm_source=tuicool&utm_medium=referral

一些有用的命令

1. 列舉 Topic: kafka-topics.bat --list --zookeeper localhost:2181

2. 描述 Topic: kafka-topics.bat --describe --zookeeper localhost:2181 --topic [Topic Name]

3. 從頭讀消息: kafka-console-consumer.bat --zookeeper localhost:2181 --topic [Topic Name] --from-beginning

4. 刪除 Topic: kafka-run-class.bat kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper localhost:2181