PushConsumer核心参数详解

1 consumeFromWhere

消费者从那个位置开始消费。

• CONSUME_FROM_LAST_OFFSET 第一次启动从队列最后位置消费，后续再启动接着上次消费的进度开始消费
• CONSUME_FROM_FIRST_OFFSET 第一次启动从队列初始位置消费，后续再启动接着上次消费的进度开始消费
• CONSUME_FROM_TIMESTAMP 第一次启动从指定时间点位置消费，后续再启动接着上次消费的进度开始消费

2 allocateMessageQueueStrategy

默认AllocateMessageQueueAveragely，Rebalance（轮询）算法实现策略。

3 subscription

订阅

4 offsetStore

消息进度存储，存储实际的偏移量，两种实现。

5 consumeThreadMin/consumeThreadMax

默认10，消费线程池数量/默认20， 消费线程数量

6 consumeConcurrentlyMaxSpan/pullThresholdForQueue

• 默认值2000， 单队列并行消费允许的最大跨度 /
• 默认1000，拉消息本地队列缓存消息最大数

7 pullInterval/pullBatchSize

默认0，拉消息间隔，由于是长轮询，所以为0，但是如果应用为了流控，也可以设置大于0的值，单位毫秒

• 默认32， 批量拉消息，一次最多拉多少条

9 consumeMessageBatchMaxSize

默认1，批量消费，一次消费多少条消息

参考

• https://www.jianshu.com/p/0948922a058d