文档中心

消息队列 RocketMQ版

Java SDK

参数说明

参数说明

本文介绍您在使用社区版 Java SDK 接入火山引擎消息队列 RocketMQ版时，需要配置的参数。

通用参数

参数名	参数说明
NAMESRV_ADDR	设置 TCP 协议接入点，从火山引擎控制台的实例详情页面获取。
AccessKey	您在火山引擎控制台-实例页面的密钥管理页面，创建的 AccessKey ID，用于身份认证。
SecretKey	您在火山引擎控制台-实例页面的密钥管理页面，创建的 AccessKey Secret，用于身份认证。

消息发送参数

参数名	参数说明
ProducerGroup	Producer 组名，多个 Producer 如果属于一个应用，发送同样的消息，则应该将它们归为同一组，即您在火山引擎 RocketMQ 控制台上创建的 Group ID。
sendMsgTimeout	发送消息超时时间，单位：毫秒。
compressMsgBodyOverHowmuch	消息 Body 超过多大开始压缩（Consumer 收到消息会自动解压缩），默认值：4，单位：KB。
retryTimesWhenSendFailed	如果消息发送失败，最大重试次数，该参数只对同步发送模式起作用。
maxMessageSize	客户端限制的消息大小，超过报错，同时服务端也会限制，所以需要跟服务端配合使用，默认值：4，单位：MB。

消息订阅参数

参数名	参数说明
consumerGroup	Consumer 组名，多个 Consumer 如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组，即您在火山引擎 RocketMQ 控制台上创建的 Group ID。
consumeFromWhere	新的 Consumer Group 启动后，用于确定从何处开始拉取，默认从最新位点拉取。
consumeThreadMin	消费线程池最小线程数，默认值：20。
consumeThreadMax	消费线程池最大线程数，默认值：20。请与最小线程数保持一致。
consumeConcurrentlyMaxSpan	单队列并行消费位点允许的最大跨度，默认值：2000，取值范围为[1,65535]。
pullThresholdForQueue	拉消息本地队列缓存消息最大数，默认值：1000，单位：条，取值范围为[1,65535]。
pullThresholdSizeForQueue	单队列本地最大缓存消息数量，默认值：100，单位：MB，取值范围为[1,1024]。
maxReconsumeTimes	最大重试次数，默认值：16，单位：次。
suspendCurrentQueueTimeMillis	顺序消息最小重试间隔，默认值：1000，单位：毫秒，取值范围为[10,30000]。

最近更新时间：2025.07.09 16:22:41

这个页面对您有帮助吗？

有用

有用

无用

无用