本文介绍您在使用社区版 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]。 |