检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 选择以下任意一种方法删除按需的RocketMQ实例。 在待删除的RocketMQ实例所在行,单击“更多 > 删除”。 单击待删除的RocketMQ实例名称
若key包含空格,则被视为多个key,在消息查询中无法以Message Key的方式准确查询出消息。 (可选)消息Tag:消息标签,用来进一步区分某个Topic下的消息分类,消息从生产者发出即带上的属性。输入长度不能超过128个字符。 页面右上角显示“消息发送成功”时,表示消息发
分布式消息服务RocketMQ版提供两种消息查询的方法:按Topic查询和按Message ID查询。 支持区域: 全部 查询消息 开启消息轨迹 消费组管理 消费组,即一组具有相同行为的消费者集合,用于管理和维护消息的消费状态。消费消息前,必须创建消费组。 支持区域: 全部 创建消费组 查询消费组信息 修改消费组参数
面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“Topic管理”,进入“Topic管理”页面。 选择以下任意一种方法修改Topic参数。 在待修改的Topic所在行,单击“编辑”,弹出“编辑Topic”页面。 单击待修改的Topic名称,进入Topi
分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 复制资源ID。 RocketMQ实例的实例费用和存储空间费用会分别上报一条账单到计费系统进行结算。查看指定资源的账单时,需要分别查看实例账单和存储空间账单。 在RocketMQ实例列表页面如下图所示位置单击鼠标左键,复制实例的资源ID。
建议将访问DMS for RocketMQ实例方式设置为密码访问(即开启ACL访问控制),防止未经认证的客户端误操作实例。 您可以选择如下任意一种方法开启ACL访问控制。 在“购买实例”页面开启ACL访问控制,具体可参考购买RocketMQ实例。 购买实例后,在实例的“基本信息”页面
是否允许以广播模式消费 是否顺序消费 group-01 16 否 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。 export
TagEntity objects 标签列表 表3 TagEntity 参数 参数类型 描述 key String 标签键。 不能为空。 对于同一个实例,Key值唯一。 长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + -
前提条件 已购买RocketMQ实例。 已开启RabbitMQ管理插件。 已购买RabbitMQ 3.7.17/3.8.35版本实例。 步骤一:获取RabbitMQ的元数据 在浏览器中输入“http://您的RabbitMQ IP地址:15672/”,进入开源RabbitMQ控制台。
分布式消息服务RocketMQ版 分布式消息服务RocketMQ版(Distributed Message Service for RocketMQ)是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。 文档 图说RocketMQ 立即使用 立即使用 成长地图 由浅入深,带您玩转分布式消息服务RocketMQ版
划线组成。 图3 设置告警名称 在“创建告警规则”界面,设置告警策略。 告警策略:连续1次原始值>=10000个时,触发重要告警,每天发送一次告警通知。 图4 设置告警策略 在“创建告警规则”界面,设置告警通知对象。 图5 设置告警通知对象 发送通知:选择开启。 通知方式:选择“主题订阅”。
是否允许以广播模式消费 group-01 broker-0 16 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。 export
objects 标签列表。 表3 TagEntity 参数 是否必选 参数类型 描述 key 否 String 标签键。 不能为空。 对于同一个实例,Key值唯一。 长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + -
resource_spec_code String 资源规格。 表3 TagEntity 参数 参数类型 描述 key String 标签键。 不能为空。 对于同一个实例,Key值唯一。 长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + -
min_offset Integer 最小偏移量。 max_offset Integer 最大偏移量。 last_message_time Long 最后一条消息的时间。 请求示例 查询指定主题的消息数。 GET https://{endpoint}/v2/{project_id}/instan
resource_spec_code String 资源规格。 表5 TagEntity 参数 参数类型 描述 key String 标签键。 不能为空。 对于同一个实例,Key值唯一。 长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + -
消费组名称。 online Boolean 消费组是否在线。 subscription_consistency Boolean 订阅关系是否一致。 total Integer 消费者总数。 next_offset Integer 下个分页的offset。 previous_offset
msg_id_list 否 Array of strings 消息ID列表。 uniq_key_list 否 Array of strings 唯一Key列表。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 [数组元素] Array of Message objects
be an array that contains only one AZ ID. 请求参数available_zones非法,必须为只包含一个可用区ID的数组。 请检查参数available_zones 400 DMS.00400068 The VPC does not exist