检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
本信息”页面。 在左侧导航栏单击“后台任务管理”,进入后台任务管理页面。 在“后台任务”或“定时任务”页签左上角选择需要查看的时间段,界面显示相应时间段内启动的后台任务或定时任务。 在后台任务管理页面,您还可以执行以下操作: 通过筛选来查询对应的RocketMQ实例。当前支持的筛
"topic" : "topic_01", "timestamp" : 1662652800000 } 响应示例 状态码: 200 重置消费进度成功。 { "queues" : [ { "broker_name" : "broker-1", "queue_id" :
Array of trace objects 消息轨迹列表。 表4 trace 参数 参数类型 描述 success Boolean 是否成功。 trace_type String 轨迹类型 timestamp Number 时间。 group_name String 生产组或消费组。
id}/instances/{instance_id}/topics?offset=0&limit=10 响应示例 状态码: 200 查询成功。 { "total" : "3,", "max" : "2000,", "remaining" : "1997,", "next_offset"
{instance_id}/groups/{group_id}/accesspolicy 响应示例 状态码: 200 消费组的授权用户列表成功。 { "policies" : { "access_key" : "test_01", "secret_key" :
"horizontal", "new_product_id" : "c6.4u8g.cluster" } 响应示例 状态码: 200 实例规格变更成功。 { "job_id" : "93b94287-728d-4bb1-a158-cb66cb0854e7" } SDK代码示例 SDK代码示例如下。
oup}/clients?offset=0&limit=10&is_detail=true 响应示例 状态码: 200 查询消费者订阅详情成功。 { "group_name" : "test", "online" : true, "subscription_consistency"
roject_id}/instances/{instance_id}/groups/{group} 响应示例 状态码: 200 查询消费组成功。 { "name" : "test", "enabled" : true, "broadcast" : true, "brokers"
"consume_orderly" : false, "retry_max_time" : 16 } ] } 响应示例 状态码: 200 批量修改消费组成功。 { "job_id" : "8abfa7b27da211df017da340427b0979" } SDK代码示例 SDK代码示例如下。
ject_id}/instances/{instance_id}/brokers 响应示例 状态码: 200 查询RocketMQ代理列表成功。 { "brokers" : [ { "ids" : [ 0, 1, 2 ], "broker_name" : "broker-0"
https://{endpoint}/v2/{project_id}/rocketmq/{instance_id}/tags 响应示例 状态码: 200 查询实例标签成功。 { "tags" : [ { "key" : "key1", "value" : "value1" }, {
oject_id}/instances/{instance_id}/topics/{topic} 响应示例 状态码: 200 查询单个主题成功。 { "total_read_queue_num" : 3, "total_write_queue_num" : 3, "permission"
修改RocketMQ消费组配置 消费组创建成功后,可以根据业务需要修改消费组的配置信息。 前提条件 已创建消费组。 修改RocketMQ消费组配置 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
instances/{instance_id}/topics/{topic}/groups 响应示例 状态码: 200 查询主题消费组列表成功。 { "groups" : [ "CID_JODIE_1", "test_consumer" ] } SDK代码示例 SDK代码示例如下。
s/{instance_id}/topics/{topic}/accesspolicy 响应示例 状态码: 200 查询主题的授权用户列表成功 { "policies" : [ ], "total" : 0, "name" : "test" } SDK代码示例 SDK代码示例如下。
"topic" : "%DLQ%group1", "msg_id_list" : [ "id1" ] } 响应示例 状态码: 200 重发死信消息成功。 { "resend_results" : [ { "msg_id" : "C0A8149E0000277600000000000B6835"
https://{endpoint}/v2/{project_id}/rocketmq/tags 响应示例 状态码: 200 查询项目标签成功。 { "tags" : [ { "key" : "key1", "values" : [ "value-test",
"name" : "group1", "perm" : "PUB|SUB" } ] } 响应示例 状态码: 200 修改成功。 { "access_key" : "test_01", "admin" : false, "default_group_perm"
instance_id}/users/{user_name}?offset=0&limit=10 响应示例 状态码: 200 查询用户详情成功。 { "access_key" : "test_01", "admin" : false, "default_group_perm"
D170010", "7F000001001C18B4AAC26B8AEE030015" ] } 响应示例 状态码: 200 导出死信消息成功。 { "topic" : "topic_01", "body" : "Hello world", "property_list"