检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
/{instance_id}/metadata 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述
实例Topic数上限:定义实例可以创建的Topic数量。 实例消费组数上限:定义实例可以创建的消费组数量。 分布式消息服务RocketMQ版5.x基础版支持的产品规格如表2和表3所示。下表中TPS是指以普通消息类型、4KB消息大小为基准计算的每秒收发消息的总条数。如果消息类型为定时消息/延时消息/事务消息,发送消息的
指定用户的默认Topic权限。 取值范围: 禁止:表示用户既不可以往Topic发送消息,也不能消费Topic中的消息。 发布:表示用户只可以往Topic发送消息,不能消费Topic中的消息。 订阅:表示用户不可以往Topic发送消息,但可以消费Topic中的消息。 发布+订阅:表示用户既可以往Topic发送消息,也可以消费Topic中的消息。
创建安全组后,系统默认添加入方向“允许安全组内的彼此通信”规则和出方向“放通全部流量”规则,此时使用内网通过同一个VPC访问RocketMQ实例,无需添加表2和表3的规则。 表2 安全组规则(RocketMQ实例4.8.0版本) 方向 协议 端口 源地址 说明 入方向 TCP 8100 RocketMQ客户端所在的IP地址或地址段。
示例代码中的参数说明如下,请参考收集连接信息获取参数值。 testGroup:表示消费组名称。 192.168.0.1:8100:表示实例连接地址和端口。 AccessKey:表示用户名。创建用户的步骤,请参见创建用户。 SecretKey:表示用户的密钥。 test:表示Topic名称。 父主题: Go(TCP协议)
g_key() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。 gid:表示生产者组名称,请根据业务实际情况输入生产者组名称。 name_srv:表示实例连接地址和端口。 上述代码中,相同orderId的消息需要保证顺序,不同order
cs/{topic} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 topic 是 String 主题名称。 请求参数 表2 请求Body参数 参数
String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 instance_id String 实例ID nodes Array of strings node列表 result String 结果 请求示例 POST http
(假设当前权限仅包含DMS ReadOnlyAccess),表示“DMS ReadOnlyAccess”已生效。 在“服务列表”中选择云硬盘(假设当前策略仅包含DMS ReadOnlyAccess),若提示权限不足,表示“DMS ReadOnlyAccess”已生效。 DMS for
单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“消费组管理”,进入消费组列表页面。 在待重置消费进度的消费组所在行,单击“重置消费进度”,弹出“重置消费进度”对话框。 参考表1,设置重置消费进度参数。 表1 重置消费进度参数说明 参数 说明 Topic名称 选择待重置消费进度的Topic。
加的标签如果不符合标签策略的规则,会添加失败。 标签共由两部分组成:“标签键”和“标签值”,其中,“标签键”和“标签值”的命名规则如表1所示。 表1 标签命名规则 参数名称 规则 标签键 不能为空。 对于同一个实例,Key值唯一。 长度为1~128个字符(中文也可以输入128个字符)。
在左侧导航栏,单击“消费组管理”,进入消费组列表页面。 选择以下任意一种方法修改消费组参数。 在待修改的消费组所在行,单击“编辑”,弹出“编辑消费组”页面。 单击待修改的消费组名称,进入消费组详情页面。在页面右上角,单击“编辑”,弹出“编辑消费组”页面。 修改如表1所示配置信息。 表1 消费组参数说明 参数
yml”文件中,增加如下内容。 accessKey:******* secretKey:******* accessKey和secretKey表示在控制台“用户管理”页面,创建的用户名和密钥,具体可参见创建用户。 进入“rocketmq-tutorial/bin”目录。 cd rocketmq-tutorial/bin
ps 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 引擎。 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数
Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 testGroup:表示消费组名称。 192.168.0.1:8100:表示实例连接地址和端口。 test:表示Topic名称。 父主题: Go(TCP协议)
yml”文件中,增加如下内容。 accessKey:******* secretKey:******* accessKey和secretKey表示在控制台“用户管理”页面,创建的用户名和密钥,具体可参见创建用户。 进入“rocketmq-tutorial/bin”目录。 cd rocketmq-tutorial/bin
SDK的接入方式,可以无缝升级到5.x。 基础版和专业版的差异 分布式消息服务RocketMQ版5.x支持两种实例类型:基础版、专业版,它们的差异如表2所示。 表2 基础版和专业版的差异 维度 基础版 专业版 目标用户 入门级、对于成本敏感的用户。 对于可靠性、性能等要求高的进阶型、企业级用户。
Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 testGroup:表示消费组名称。 192.168.0.1:8100:表示实例连接地址和端口。 test:表示Topic名称。 父主题: Go(TCP协议)
通过密文传输,传输方式由客户端决定。 操作影响 RocketMQ实例修改接入方式会存在如表1所示的影响。 部分存量RocketMQ实例不支持“PERMISSIVE”,具体以控制台显示为准。 表1 修改接入方式的影响 服务端接入方式 影响 PLAINTEXT > SSL 存量实例会
strings 消息ID列表。 uniq_key_list 否 Array of strings 唯一Key列表。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 [数组元素] Array of Message objects 消息。 表4 Message 参数