Kafka其實只是眾多消息隊列中的一種,對於Kafka的具體釋義我這里就不多說了,詳見:http://baike.baidu.com/link?url=HWFYszYuMdP_lueFH5bmYnlmH--SlsarbzE1CcfMi9JqeQBR77jCu30MubmAyBqqOSSZy9qfnrp5y5a_8wYota
想要下載Kafka可以直接上官網:http://kafka.apache.org/ (強烈建議一定要上官網下載,其它地方下載的可能有問題)
Kafka下載成功之后,在libs文件夾下面就是相關的jar包,如果使用Java開發就可以直接引入項目即可。同時在bin文件夾下面就是運行Kafka所需要的文件,Windows里面表示在Windows上面運行所需要的文件。相關運行的命令如下:
//跳轉到指定目錄,必須跳轉到Kafka目錄才能運行后面的命令 cd C:\soft\kafka_2.10-0.8.2.2 //啟動zookeeper bin\windows\zookeeper-server-start.bat config\zookeeper.properties //啟動server。注意和啟動zookeeper的先后順序,同時這兩個啟動項需要分別在dos下運行 bin\windows\kafka-server-start.bat config\server.properties //創建一個主題 topic bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test //查看所有創建的主題 bin\windows\kafka-topics.bat --list --zookeeper localhost:2181 //開始消費topic bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic mytest --from-beginning //生產數據 bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic mytest
這是通過服務器直接操作kafka的常用命令,而Java調用Kafka除了引用上面提到的jar包之外就是編碼了,具體編碼可參考:http://www.cnblogs.com/liuming1992/p/6432626.html
Kafka中有很多的概念,比如groupid,partitions,topic等等。在使用之前一定要把這些概念搞清楚了才能寫出可靠的代碼。
上面都是Windows的相關命令,下面是Linux的命令
//跳轉到指定目錄,必須跳轉到Kafka目錄才能運行后面的命令 cd /usr/local/kafka //啟動zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties //啟動server。注意和啟動zookeeper的先后順序,同時這兩個啟動項需要分別在dos下運行(可開啟兩個界面) bin/kafka-server-start.sh config/server.properties //創建一個主題 topic ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test //查看所有創建的主題 ./bin/kafka-topics.sh --list --zookeeper localhost:2181 //開始消費topic bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning //生產數據 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
