PushConsumer核心参数详解

    科技2025-06-01  35

    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 公众号-JavaEdge 认证博客专家 博客专家 慕课网认证作者 腾讯云+最佳作者 1.经历:19届双一流本科,曾在百度、携程、华为等大厂搬金砖2.涉猎领域:Java生态各种中间件原理、框架源码、微服务、中台等架构设计及落地实战,只生产硬核干货!3.开源社区荣誉:阿里云栖社区博客专家、腾讯云+社区2019年度最佳作者、慕课网认证作者、百万流量万粉博客专家,简书优秀创作者兼《程序员》专题管理员4.著作:在牛客网著有《Java源码面试解析指南》,目前已有上千人在学习,已助众多读者成功拿到满意offer~
    Processed: 0.009, SQL: 8