kafka

創(chuàng)新互聯(lián)建站是專業(yè)的蚌山網(wǎng)站建設(shè)公司，蚌山接單;提供網(wǎng)站設(shè)計制作、做網(wǎng)站,網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行蚌山網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊,希望更多企業(yè)前來合作!

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

rockermq

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