检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
查询主题消费组列表 功能介绍 查询主题消费组列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/topics/{topic}/groups 表1 路径参数 参数 是否必选 参数类型 描述 project_id
重发死信消息 功能介绍 重发死信消息。 调用方法 请参见如何调用API。 URI POST /v2/{engine}/{project_id}/instances/{instance_id}/messages/deadletter-resend 表1 路径参数 参数 是否必选 参数类型
删除指定消费组 功能介绍 删除指定消费组。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 project_id
删除指定的实例 功能介绍 删除指定的实例,释放该实例的所有资源。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
查询用户详情 功能介绍 查询用户详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
当消费组的数量达到上限后,您无法继续创建消费组。 是否需要创建消费组、消费者、生产者 不需要单独创建消费组、生产者和消费者,在使用时自动生成,实例创建后,直接使用即可。 消费位点重置 支持重置消费2天内任意时间点的消息。 重置消费进度 重置消费进度可能会导致重复消费。 代理故障场景
批量修改消费组 功能介绍 批量修改消费组。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。
删除用户 功能介绍 删除用户。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
查询代理列表 功能介绍 查询代理列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/brokers 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。
查询可用区 功能介绍 查询可用区。 调用方法 请参见如何调用API。 URI GET /v1.0/availableZones 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 region_id String 区域ID。 available_zones
x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
and Access Management,简称IAM),支持三种身份认证方式:用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。 访问控制 对企业中的员工设置不同的DMS for RocketMQ访问权限,以达到不同员工之间的权限隔离,使用IAM进行精细的
导出死信消息 功能介绍 导出死信消息。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/messages/export 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
查询产品规格 功能介绍 查询产品规格信息。 调用方法 请参见如何调用API。 URI GET /v1.0/products 表1 Query参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 product_id 是 String 产品ID。
如果消费者A和消费者B设置了相同的消费组,当生产者发送Tag A的消息时,Tag A的消息会均匀发送给消费者A和消费者B。由于消费者B没有订阅Tag A的消息,会把Tag A消息过滤掉,从而导致部分Tag A消息未被消费。 图1 错误的消费组设置 这种情况下,把消费者A和消费者B设置不同的消费组,即可解决消费混乱的问题。
查询用户列表 功能介绍 查询用户列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/users 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。
创建实例 功能介绍 创建实例,该接口支持创建按需和包周期两种计费方式的实例。 调用方法 请参见如何调用API。 URI POST /v2/{engine}/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎。
Topic问题 支持多少个Topic? 是否支持自动创建Topic? Topic名称的命名规则是什么?
本章节主要测试RocketMQ实例4.8.0版本不同产品规格在发送1KB大小的消息,且CPU使用率达到80%以上时,实例的网络入流量、网络出流量、消息生产速率、消息消费速率、CPU核均负载和内存使用率。 测试环境 进行测试前,您需要先构建如下的测试环境: 购买如表1所示实例,购买步骤请参考购买实例。
查询RocketMQ产品规格核数 功能介绍 查询RocketMQ产品规格核数。 调用方法 请参见如何调用API。 URI GET /v2/rocketmq/products/cores 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 core_nume