消息隊列Kafka學習記錄


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

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM