检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
ces/{instance_id}/users/{user_name} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
2 ], "broker_name" : "broker-0" } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
"key" : "key2", "value" : "value2" } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
} ], "broker_name" : "broker-0" } } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。 export JAVA_HOME=/root/jdk1.8.0_231 export
"finished", "type" : "rabbitToRocket" } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
"policies" : [ ], "total" : 0, "name" : "test" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
Topic管理 查看RocketMQ Topic详情 修改RocketMQ Topic配置 删除RocketMQ Topic 父主题: 配置Topic
"" }, "total" : 1, "name" : "test" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
"queue_id" : 0, "timestamp_offset" : 0 } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 重置topic_01主题的消费进度到指定时间点。 1 2 3 4 5 6 7 8 9 10 11 12
"retry_max_time" : 16, "broadcast" : true } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 修改consumer-group-test消费组的参数,最大重试次数修改为16。 1 2 3 4 5 6 7
配置消息堆积数监控 方案概述 在消息处理过程中,如果客户端的消费速度跟不上服务端的发送速度,未处理的消息会越来越多,这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积,从而会造成消息消费延迟。 如果您想要在消费组的消息堆积数超过阈值时,通过短信/邮件及时收到通知信息,
"next_offset" : -1, "previous_offset" : -1 } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
"topic_perms" : [ ], "white_remote_address" : "" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
null, "from_transaction_check" : false } ] SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
} ], "message_type" : "NORMAL" } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
00000000", "error_message" : "Success." } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 重发死信消息。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
00000000", "error_message" : "Success." } ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 消费验证。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。 export JAVA_HOME=/root/jdk1.8.0_231 export
查看监控指标与配置告警 查看RocketMQ监控指标 RocketMQ支持的监控指标 配置RocketMQ监控告警