kafka 集群搭建
檢查是否安裝jdk,如果沒有安裝,需要先安裝jdk。
需要先搭建zookeeper集群。
修改配置檔案
#修改配置檔案名稱
cp zoo_sample.cfg zoo.cfg
#增加server ip位址
server.0=172.16.111.128:2888:3888
server.1=172.16.111.129:2888:3888
server.2=172.16.111.130:2888:3888
#在datadir目錄中建立myid檔案myid編號為service.x對應編號
啟動3臺伺服器情況,有兩台follower 有一台leader
修改server.properties配置檔案
broker.id=0
listeners=plaintext:/
/192.168.146.200:9092
zookeeper.connect=ip1:2181,ip2:2181,ip3:2181
啟動kafka就可以了
.
/kafka-server-
start
.sh .
./config/server.properties
#後台啟動
./kafka-server-
start
.sh -daemon .
./config/server.properties
我們可以安裝乙個kafka tool 來看一下傳送環境及傳送訊息的具體內容。 訊息中介軟體 kafka入門
訊息中介軟體有 activemq,rabbitmq,rocketmq,kafka,一般在 rabbitmq 和 kafka 間進行選擇 activemq 在別處看的,說沒有經過大規模吞吐的測試,社群不活躍 rocketmq 社群有黃掉的風險,碰到問題容易找不到技術資料 kafka 社群活躍度很高 在...
kafka與rabbitmq訊息中介軟體
kafka與rabbitmq xmind 思維導圖 axure 原型設計 一 rabbitmq集群 1.1普通集群 rabbitmq 每個節點上有乙個broker,每個broker負責本機上佇列的維護,並且borker之間可以互相通訊。集群中有兩個佇列a和b,每個佇列都分為master queue和...
訊息中介軟體
1.訊息的優先順序 2.訊息排序 3.訊息過濾 4.訊息持久化 5.訊息重試 6.事務的支援 7.broker滿 生產者,佇列,消費者 訊息佇列的優點 1 解耦2 非同步訊息,系統響應 在jms中,有兩種訊息模型 點對點模式和發布訂閱模式。1.在點對點模式中 有三種角色 1 訊息佇列,傳送者,接受者...