最近到了一家新公司,很多全新技術棧要理解。每天都在看各類 english offcial document,我的宗旨是我既然看懂了,就寫下來分享,這是第一篇。
1、已有 zookeeper 集群
2、kafka 搭建請務必準備三颱伺服器
2、上傳伺服器解壓
tar xzvf kafka_2.11-1.1.0.tgz
3、修改配置檔案
broker.id=1 # 必改項
num.network.threads=3 # 網路請求執行緒數
num.io.threads=8 # io執行緒數
num.partitions=3 # 每個 topic 的分割槽數
log.dirs=/home/kafka/kafka-log # kafka topic資料存放位址
log.retention.hours=72 # 資料儲存小時數,預設是168
zookeeper.connect=192.168.1.1:2181,192.168.1.2:2181,192.168.1.3:2181
zookeeper.connection.timeout.ms=6000 # zookeeper 連線超時時間
4、啟動 kafka
kafka/bin/kafka-server-start.sh kafka/config/server.properties
# 建立主題
kafka/bin/kafka-topics.sh --create --zookeeper 192.168.1.162:2181 --replication-factor 1 --partitions 1 --topic opstest
# 生產者生產資料
kafka/bin/kafka-console-producer.sh --broker-list 192.168.1.163:9092 --topic opstest
# 消費者消費資料
kafka/bin/kafka-console-consumer.sh --zookeeper 192.168.1.173:2181 --topic opstest --from-beginning
好久沒有來
雖然寫了麗江15日遊但是沒有去成,不過也去了幾個地方,重要的是和在大學一關係要好的同學玩了兩天,其實是在我追了很久的女孩 今天是在新公司第一天上班的日子,以後還得繼續寫這個了,不過,不打算一天一寫了,一天一寫寫多了覺的廢話實在是多,平時每天上下班,也不會有什麼大事 這家新公司用的springmvc,...
好久沒有更新我的Blog了
前一段時間要麼就是太忙沒空,要麼就是有空但是太累了想休息一下 還是太忙了。再不就是乾脆懶得更新,總之就是一大堆理由 一直沒有更新blog 今天痛下決心準備近期寫一篇關於使用vb.net怎樣編寫自已的表示式解析器的文章,因為前段時間在 裡面閒逛時,發現了幾個都在問這方面的內容,以前用vb6.0時可以使...
好久沒有部落格啦
時間真快,晃眼間沒寫部落格也快一年,開始寫部落格也就一年。學業快結束啦,現在有時間,就回歸部落格,發發文章權當積累咯。先不談技術,談生活。日益明白身體是革命的本錢啊,所以吭哧吭哧準備培養一項運動,就選擇跑步咯,跑步當然要先專業一點啦,否則對膝蓋不好,練馬步,上跑步聖經論壇,根據腳型買跑步鞋,哦呵呵,...