参数说明

setInstanceName

在单个进程启动多个客户端时必选

客户端标识（Client ID）。一个进程中需要创建多个 RocketMQ 客户端连接不同实例时，需要通过 InstanceName 区分客户端连接。

producer.setInstanceName("instance")

setSendMsgTimeout

可选

发送消息的超时时间，时间单位 ms，默认 3000 ms。

producer.setSendMsgTimeout(5 * 1000)

setRetryTimes

可选

重试次数。默认 5 次。

producer.setRetryTimes(3)

setMaxMessageSize

可选

单条消息大小，单位为 KB，默认 128KB。

primitive.Interceptor

setSessionCredentials

必选

RocketMQ实例的密钥，即您在火山引擎控制台中、RocketMQ实例的密钥管理页面创建的密钥，用于身份认证。
注意：此处的密钥并非火山引擎主账号AccessKey。

producer.setSessionCredentials("accessKey", "secretKey", "accessChannel")

setCompressMsgBodyOverHowmuch

可选

消息长度超过该数值将自动将消息进行压缩，默认为4 KB，单位为字节。

producer.setCompressMsgBodyOverHowmuch(4 * 1024)

setTransactionListener

可选

事务消息监听器，事务消息必须设置。

producer.setTransactionListener(new MyTransactionListener())

setMessageModel

可选

消费模式。默认为 CLUSTERING，即集群模式。

• BROADCASTING 广播模式
• CLUSTERING 集群模式

consumer.setMessageModel(CLUSTERING)

setConsumeFromWhere

可选

新的 Consumer Group 启动后，用于确定从何处开始拉取，只有第一次设置才会生效。取值包括：

• CONSUME_FROM_LAST_OFFSET：从上次消费位置继续消费。新建的Consumer Group选择此参数将从起始位置开始消费。
• CONSUME_FROM_FIRST_OFFSET：从起始位置开始消费。选择此参数时，可能发生重复消费，请根据实际业务情况选择。
• CONSUME_FROM_TIMESTAMP：从指定时间戳开始消费。小于指定时间戳的消息将不会被消费。

consumer.setConsumeFromWhere(CONSUME_FROM_LAST_OFFSET);

setConsumeThreadCount

可选

设置消费线程的数量。

consumer.setConsumeThreadCount(5)

setSessionCredentials

必选

RocketMQ实例的密钥，即您在火山引擎控制台中、RocketMQ实例的密钥管理页面创建的密钥，用于身份认证。
注意：此处的密钥并非火山引擎主账号AccessKey。

consumer.setSessionCredentials("ak", "sk", "VOLC");

setMaxReconsumeTimes

可选

消费最大重试次数，默认为 -1，即重试 16 次。

consumer.setMaxReconsumeTimes(10)

setMaxCacheMsgSizePerQueue

可选

每个队列可以缓存的数据大小，单位为字节，默认为 1KB。

consumer.setMaxCacheMsgSizePerQueue(1000)