检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
响应示例 状态码: 200 重置消费进度成功。 { "queues" : [ { "broker_name" : "broker-1", "queue_id" : 0, "timestamp_offset" : 0 } ] } 状态码 状态码 描述 200
Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 消费验证成功。 错误码 请参见错误码。 父主题: 消息管理
Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 批量修改消费组成功。 错误码 请参见错误码。 父主题: 消费组管理
Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 重发死信消息成功。 错误码 请参见错误码。 父主题: 消息管理
消费验证是将消息重新发送到指定的在线客户端,验证消费者能否收到消息。消费验证会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时,才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态,且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费 登录管理控制台。 在管理控制台左上角单击,选择区域。
的筛选条件为状态、名称、版本、实例类型、规格、已用/可用存储空间、计费模式、可用区、企业项目和标签。RocketMQ实例状态请参见表1。 表1 RocketMQ实例状态说明 状态 说明 创建中 创建RocketMQ实例后,在RocketMQ实例状态进入运行中之前的状态。 运行中 RocketMQ实例正常运行状态。
以及对监控指标进行排序。 例如,在“节点”页签中,只需要展示“消息生产数”和“消息消费数”,请按照如下步骤操作。 在“节点”页签下,单击“设置监控指标”,弹出“设置监控指标”页面。 勾选“消息生产数”和“消息消费数”,单击“确定”。 监控指标设置成功后,选中监控指标,并拖动到需要展示的位置,完成监控指标的排序。
0版本不同产品规格在发送1KB大小的消息,且CPU使用率达到80%以上时,实例的网络入流量、网络出流量、消息生产速率、消息消费速率、CPU核均负载和内存使用率。 测试环境 进行测试前,您需要先构建如下的测试环境: 购买如表1所示实例,购买步骤请参考购买实例。 表1 实例参数 名称 规格 代理数量
附录 状态码 错误码 实例状态说明 获取项目ID 获取账号名和账号ID
动创建Topic,然后才能进行生产消息和消费消息。 支持区域: 全部 创建Topic 查询Topic信息 修改Topic参数 变更实例规格 RocketMQ实例创建成功后,您可以根据业务需要,扩容存储空间和代理个数。不支持同时扩容存储空间和代理个数,如果需要可以分别进行扩容。 当
RocketMQ实例生命周期 RocketMQ实例从购买到到期前,处于正常运行阶段,资源状态为“运行中”。 到期后,资源状态变为“已过期”。 到期未续费时,RocketMQ实例首先会进入宽限期,宽限期到期后仍未续费,资源状态变为“已冻结”。 超过宽限期仍未续费将进入保留期,如果保留期内仍未续费,资源将被自动删除。
Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 创建主题或批量删除主题成功。 错误码 请参见错误码。 父主题: Topic管理
响应示例 状态码: 200 批量删除实例成功。 { "results" : [ { "result" : "success", "instance" : "019cacb7-4ff0-4d3c-9f33-f5f7b7fdc0e6" } ] } 状态码 状态码
Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 创建成功。 错误码 请参见错误码。 父主题: 元数据迁移
Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 创建消费组或批量删除消费组成功。 错误码 请参见错误码。 父主题: 消费组管理
SetKeys:输入消息的Key。 SetTag:输入消息的Tag。 事务消息需要生产者构建一个事务检查器,用于检查确认异常半事务的中间状态,可以返回3种事务状态: TransactionResolution.COMMIT:提交事务,允许消费者消费该消息。 TransactionResolution
例如:原实例的Topic包含Topic01和Topic02,云上实例的Topic包含Topic01和Topic03,不开启同名覆盖,原实例Topic01的迁移将失败。 元数据 上传RabbitMQ的元数据。 单击“确定”。 迁移完成后,在迁移任务列表页面查看“任务状态”。 当“任务状态”为“迁移完成”,表示所有元数据都已成功迁移。
producer.close(); } } 事务消息需要生产者构建一个事务检查器,用于检查确认异常半事务的中间状态,可以返回3种事务状态: TransactionResolution.COMMIT:提交事务,允许消费者消费该消息。 TransactionResolution
概念、原理以及实施方法。 消息堆积处理建议 本章节介绍出现消息堆积的主要原因和实施方法。 配置消息堆积数监控 本章节介绍RocketMQ通过云监控配置告警规则的具体操作,以便您可以实时监控实例的运行状态和关键的业务指标,并能够及时收到异常的告警通知,实现生产环境的风险预警。 DMS
删除RocketMQ Topic 如果某个Topic不再使用,可参考本章节删除Topic,释放资源。 仅在实例的“状态”为“运行中”时,才可以删除实例中的Topic。 前提条件 已购买RocketMQ实例。 已创建Topic。 删除Topic 登录管理控制台。 在管理控制台左上角单击,选择区域。