本文介绍您在使用社区版 SDK 接入火山引擎消息队列 RocketMQ版时,需要配置的参数,以JAVA为例,其他SDK仅名称不同,但含义一致
参数名 | 参数说明 |
---|---|
endpoints | 设置 接入点信息,从火山引擎控制台的实例详情页面获取 |
requestTimeout | grpc请求超时时间 |
sessionCredentialsProvider | accessKey:火山accesskey信息 |
sslEnabled | 是否开启底层grpc tls/ssl模式,火山暂不支持,填写false即可 |
namespace | topicg/group等资源命名空间,火山为用户独占实例,不支持也无需支持该参数 |
参数名 | 参数说明 |
---|---|
checker | 事务消息设置服务端回查逻辑 |
maxAttempts | 发送重试的最大次数 |
参数名 | 参数说明 |
---|---|
messageListener | pushConsumer 注册的消息处理函数 |
maxCacheMessageCount | 缓冲的最大消息数量上限,默认1024。每个queue的上限为maxCacheMessageCount/queueNumber |
maxCacheMessageSizeInBytes | 缓冲的最大消息大小数量上限,默认64KB。每个queue的上限为maxCacheMessageSizeInBytes/queueNumber |
consumptionThreadCount | 业务消费线程池线程数,默认值:20 |