6.10 Client RocketMQ

范式

参考地址 (opens new window)

RocketMQConfig

配置项

名称	类型	描述
configName	string	该mq配置名
enable	bool	是否开启
addr	[]string	地址
group	string	消费组，默认为空
topic	string	消费topic，默认为空
subExpression	string	标签，默认为*
rate	int	消费速率，默认为0，不限速
....

示例

[jupiter.rocketmq]
[jupiter.rocketmq.configName]
[jupiter.rocketmq.configName.consumer]
enable = true
addr = ["127.0.0.1:9876"]
group = "test_group"
topic = "test_topic"
subExpression = "*"
rate = 1
[jupiter.rocketmq.configName.producer]
addr = ["127.0.0.1:9876"]
group = "test_group"
topic = "test_topic"