3、重新命名conf/zoo_sample.cfg 為conf/zoo.cfg
4、編輯 conf/zoo.cfg，修改datadir=d:\zookeeper-3.3.6\data\
4、執行bin/zkserver.cmd
啟動結果如下：
2、開啟config目錄下的server.properties， 修改log.dirs為d:\kafka_logs,
3、修改advertised.host.name=伺服器ip
4、啟動kafka ./bin/windows/kafka-server-start.bat ./config/server.preperties
kafka也提供了乙個命令列消費者，接受訊息並列印到標準輸出。
)//訊息寫入kafka
func main() , config)
if err != nil
defer client.close()
var n int=0
for n<20
msg.topic = "nginx_log"
msg.value = sarama.stringencoder("this is a good test,hello chaoge!!")
//傳送訊息
pid, offset, err := client.sendmessage(msg)
if err != nil
fmt.printf("pid:%v offset:%v\n,", pid, offset)
time.sleep(10 * time.millisecond)
}}
goland執行結果：kafka收到的資料：
Golang訊息佇列之NSQ
目錄nsq安裝 nsq是乙個實時分布式訊息傳遞平台，設計用於大規模操作，能每天處理數十億條訊息。它促進了沒有單點故障的分布式和分散拓撲，支援容錯和高可用性，並提供可靠的訊息傳遞保證。優缺點 優點 1 部署非常方便，沒有任何環境的依賴，乙個二進位制可執行檔案 2 輕量級沒有過多的配置引數，只需要簡單配...
python之微信自動傳送訊息
如下 from future import unicode literals from threading import timer from wxpy import import requests bot bot defsend news try my friend bot.friends sea...
golang微信公眾平台之訊息接入
api文件上的內容 引數描述 signature timestamp 時間戳 nonce 隨機數 echostr 隨機字串 校驗流程 1.將token timestamp nonce三個引數進行字典序排序 2.將三個引數字串拼接成乙個字串進行sha1加密 go搭建乙個web伺服器 當然我這裡刪掉了不...