rocketmq-consumer-start

文档摘要

该文所涉及的 RocketMQ 源码版本为 4.9.3。 RocketMQ 消费者启动流程 org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl#start org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl#checkConfig 校验消费组的长度不能大于 255 消费组名称只能包含数字、字母、%、-、\、消费组名称不能是消费者最小线程数需要在 1-1000 之间消费者最大线程数需要在 1-1000 之间构造主题订阅消息并将其加入，如果是消费模式是集群，订阅默认的重试主题并且构造加入创建，