Kafka 部署指南 好久沒有更新部落格了

2022-01-24 13:38:56 字數 1123 閱讀 4429

最近到了一家新公司,很多全新技術棧要理解。每天都在看各類 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時可以使...

好久沒有部落格啦

時間真快,晃眼間沒寫部落格也快一年,開始寫部落格也就一年。學業快結束啦,現在有時間,就回歸部落格,發發文章權當積累咯。先不談技術,談生活。日益明白身體是革命的本錢啊,所以吭哧吭哧準備培養一項運動,就選擇跑步咯,跑步當然要先專業一點啦,否則對膝蓋不好,練馬步,上跑步聖經論壇,根據腳型買跑步鞋,哦呵呵,...