溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
kafka
topic下的一個分區只能被同一個consumer group下的一個consumer線程來消費，但反之并不成立，即一個consumer線程可以消費多個分區的數據，比如Kafka提供的ConsoleConsumer，默認就只是一個線程來消費所有分區的數據。所以即分區數決定了同組消費者個數的上限
rockermq
rocketmq的topic中有隊列(queue)的概念，也就是說一個節點上面可以有多個隊列，這樣能非常大的提高并發性，而kafka最多只能是一個分區一個進程消費，這樣并發性限制非常大，并且單機分區數量不能過多，超過64個分區就出現明顯的不穩定，但是rocketmq單機支持上萬隊列，所以并發性能非常好；
創建命令
sh /root/rocketmq/bin/mqadmin updateTopic -c whk -n "ip" -t offer -r 1 -w 1 -o true
參數說明
創建topic需要指定的參數，????-b 指定broker上創建topic????-c 指定cluster創建topic????-n 指定namesrv地址，cluster模式下必須從namesrv獲取broker地址????-t topic的名字標志????-r/w 讀寫隊列的個數，建議相等????-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
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
