rocketMq - 并发消费过程
rocketMq消费过程包括两种，分别是并发消费和有序消费，每个消费方式都可以单独拿出来进行分享，这篇文章单独用来分析并发消费问题。
并发消费需要理解的几个核心点：并发消费的消息拉取，并发消费的消息重试，并发消息的ack机制，消费进度的持久化，这篇分享会就这几个问题分解展开。
MQ NameServer模块划分
上图是之前讨论确定的系统架构（后续内容会按照这个架构来叙述），其中：
NameServer做Broker的服务发现，即客户端可以通过NameServer拿到Broker的信息
Broker汇报数据到NameServer
NameServer的模块划分
在进行N...
RocketMQ问题排查思路
1、使用HTTP协议报错500。排查思路： 1）. 是不是有tcp的producer在发送。 2）. 是不是有大量的非法字符。建议单独建一个topic给http，然后再进行测试。
2、报没有权限： 1). 如果是主账号：确保GID和topic都是主账号创建； 2). 如果是子账号：确保GID是子账号创建，并且topic授权这个ak使用。
Pulsar-Producer实现简介
“Pulsar is a distributed pub-sub messaging platform with a very flexible messaging model and an intuitive client API.”
Pulsar是pub-sub模式的分布式消息平台，拥有灵活的消息模型和直观的客户端API。