消息队列 RocketMQ 消费者核心配置 ​

consumeFromWhere配置 ​

(某些情况失效:参考https://blog.csdn.net/a417930422/article/details/83585397)

• CONSUME_FROM_FIRST_OFFSET: 初次从消息队列头部开始消费，即历史消息(还储存在 broke r的)全部消费—遍，后续再启动接着上次消费的进度开始消费
• CONSUME_FROM_LAST_OFFSET: 默认策略，初次从该队列最尾开始消费，即跳过历史消息，后续再启动接着上次消费的进度开始消费
• CONSUME_FROM_TIMESTAMP : 从某个时间点开始消费，默认是半个小时以前，后续再启动接着上次消费的进度开始消费

allocateMessageQueueStrategy: ​

负载均衡策略算法，即消费者分配到queue的算法，默认值是 AllocateMessageQueueAveragely 即取模平均分配

offsetStore: ​

消息消费进度存储器 offsetStore 有两个策略：
LocalFileOffsetStore 和 RemoteBrokerOffsetStor。
广播模式默认使用 LocalFileOffsetStore；
集群模式默认使用 RemoteBrokerOffsetStore

consumeThreadMin ​

最小消费线程池数量

consumeThreadMax ​

最大消费线程池数量

pullBatchSize ​

消费者去broker拉取消息时，—次拉取多少条，可选配置

consumeMessageBatchMaxSize ​

单次消费时—次性消费多少条消息，批量消费接口才有用，可选配置

messageModel ​

消费者消费模式，CLUSTERING —— 默认是集群模式；BROADCASTING ——广播模式