卡夫卡
主题下的一个分区只能被同一个消费者组织下的一个消费线程来消费,但反之并不成立,即一个消费线程可以消费多个分区的数据,比如卡夫卡提供的ConsoleConsumer,默认就只是一个线程来消费所有分区的数据,所以即分区数决定了同组消费者个数的上限
rockermq
rocketmq的话题中有队列(队列)的概念,也就是说一个节点上面可以有多个队列,这样能非常大的提高并发性,而卡夫卡最多只能是一个分区一个进程消费,这样并发性限制非常大,并且单机分区数量不能过多,超过64个分区就出现明显的不稳定,但是rocketmq单机支持上万队列,所以并发性能非常好;
创建命令
sh/root/rocketmq/bin/mqadmin updateTopic - c whk - n“ip"- t - r 1 - w - o提供真正的
参数说明
创建主题需要指定的参数,- b指定代理上创建主题- c指定集群创建主题- n指定namesrv地址,集群模式下必须从namesrv获取代理地址- t主题的名字标志- r/w读写队列的个数,建议相等- p队列的读写权限- 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
