rockermq&kafka消費限制-創(chuàng)新互聯(lián)

kafka

成都創(chuàng)新互聯(lián)是一家專注于成都網站建設、成都做網站與策劃設計,玉門網站建設哪家好?成都創(chuàng)新互聯(lián)做網站,專注于網站建設十余年,網設計領域的專業(yè)建站公司;建站業(yè)務涵蓋:玉門等地區(qū)。玉門做網站價格咨詢:13518219792

topic下的一個分區(qū)只能被同一個consumer group下的一個consumer線程來消費，但反之并不成立，即一個consumer線程可以消費多個分區(qū)的數(shù)據(jù)，比如Kafka提供的ConsoleConsumer，默認就只是一個線程來消費所有分區(qū)的數(shù)據(jù)。所以即分區(qū)數(shù)決定了同組消費者個數(shù)的上限

rockermq

rocketmq的topic中有隊列(queue)的概念，也就是說一個節(jié)點上面可以有多個隊列，這樣能非常大的提高并發(fā)性，而kafka最多只能是一個分區(qū)一個進程消費，這樣并發(fā)性限制非常大，并且單機分區(qū)數(shù)量不能過多，超過64個分區(qū)就出現(xiàn)明顯的不穩(wěn)定，但是rocketmq單機支持上萬隊列，所以并發(fā)性能非常好；

創(chuàng)建命令

sh /root/rocketmq/bin/mqadmin updateTopic -c whk -n "ip" -t offer -r 1 -w 1 -o true

參數(shù)說明

創(chuàng)建topic需要指定的參數(shù)，????-b 指定broker上創(chuàng)建topic????-c 指定cluster創(chuàng)建topic????-n 指定namesrv地址，cluster模式下必須從namesrv獲取broker地址????-t topic的名字標志????-r/w 讀寫隊列的個數(shù)，建議相等????-p queue的讀寫權限????-o 待研究不確定是不是保證全局有序消息的配置

rocketmq 注意點

https://blog.csdn.net/zhaozhenzuo/article/details/76791495

參考
https://blog.csdn.net/chunlongyu/article/details/54018010
https://www.cnblogs.com/freeweb/p/7817968.html

另外有需要云服務器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

新聞名稱：rockermq&kafka消費限制-創(chuàng)新互聯(lián)
文章源于：http://muchs.cn/article46/dhgchg.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供網站導航、品牌網站設計、網頁設計公司、外貿建站、面包屑導航、微信小程序

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)