rockermq & kafka 消費限制

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