kafka

成都創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站建設、成都做網(wǎng)站與策劃設計,玉門網(wǎng)站建設哪家好?成都創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設十余年,網(wǎng)設計領域的專業(yè)建站公司;建站業(yè)務涵蓋:玉門等地區(qū)。玉門做網(wǎng)站價格咨詢: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的讀寫權(quán)限????-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，海內(nèi)外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

當前題目：rockermq&kafka消費限制-創(chuàng)新互聯(lián)
標題路徑：http://weahome.cn/article/dhgchg.html