检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
一个Region中的多个AZ间通过高速光纤相连，以满足用户跨AZ构建高可用性系统的需求。 项目 区域默认对应一个项目，这个项目由系统预置，用来隔离物理区域间的资源（计算资源、存储资源和网络资源），以默认项目为单位进行授权，用户可以访问您账号中该区域的所有资源。
通过脚本将Topic和消费组列表导入到华为云上RocketMQ实例中 登录已准备的Linux系统主机，下载RocketMQ软件包。
") sk := os.Getenv("CLOUD_SDK_SK") projectId := "{project_id}" auth := basic.NewCredentialsBuilder().
重置RocketMQ消费进度 重置消费进度即修改消费者的消费位置，重置消费进度后，消费者会从修改后的消息位置开始继续消费。 重置消费进度可能会导致重复消费，请谨慎操作。 操作视频 本视频演示重置RocketMQ消费进度的操作。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建
= nil { fmt.Println(err.Error()) os.Exit(-1) } time.Sleep(time.Hour) err = c.Shutdown() if err !
DMS for RocketMQ支持敏感操作保护，开启后执行删除实例等敏感操作时，系统会进行身份验证，进一步对数据的高危操作进行控制，保证DMS for RocketMQ数据的安全性。详情请参见敏感操作。
监控安全风险 DMS for RocketMQ提供基于云监控服务CES的资源和操作监控能力，帮助用户对每个RocketMQ实例进行自动实时监控、告警和通知操作。用户可以实时掌握实例的各类业务请求、资源占用、流量、连接数和消息积压等关键信息。 关于DMS for RocketMQ支持的监控指标
SecretKey = os.Getenv("ROCKETMQ_SK") ) func main() { os.Setenv("mq.consoleAppender.enabled", "true") golang.ResetLogger() producer
为什么查询到的消费组不在控制台中？ 使用Admin Tool连接RocketMQ实例查询消费组信息时，会查出一些控制台中没有配置的消费组，如CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_ONSAPI_PERMISSION
= nil { fmt.Println(err.Error()) os.Exit(-1) } time.Sleep(time.Hour) err = c.Shutdown() if err !
SecretKey = os.Getenv("ROCKETMQ_SK") ) func main() { os.Setenv("mq.consoleAppender.enabled", "true") golang.ResetLogger() producer
图1 综合推荐 规格测算：系统根据您输入的参数（Topic个数、生产TPS峰值、消费TPS峰值、平均消息大小和日生产消息数），为您计算出不同规格所需的代理个数和代理存储空间，您根据实际情况选择。5.x版本不支持规格测算。 图2 规格测算 设置网络信息。
") sk := os.Getenv("CLOUD_SDK_SK") projectId := "{project_id}" auth := basic.NewCredentialsBuilder().
") sk := os.Getenv("CLOUD_SDK_SK") projectId := "{project_id}" auth := basic.NewCredentialsBuilder().
") sk := os.Getenv("CLOUD_SDK_SK") projectId := "{project_id}" auth := basic.NewCredentialsBuilder().
SINGLE_TAG：单标签 MULTI_TAG：多标签 topicSysFlag 否 Integer Topic系统标志位。
配置RocketMQ监控告警 本章节主要介绍部分监控指标的告警策略，以及配置操作。在实际业务中，建议按照以下告警策略，配置监控指标的告警规则。 是否接近性能上限，表示当前资源支撑的性能为告警策略中设置的告警阈值，如果继续上升，业务可能出现问题。 表1 RocketMQ实例配置告警的指标
收发普通消息 本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送和异步发送。RocketMQ提供PushConsumer和SimpleConsumer类型的消费者，PushConsumer消费者订阅普通消息时，代码不区分同步订阅和异步订阅。SimpleConsumer
SecretKey = os.Getenv("ROCKETMQ_SK") ) func main() { os.Setenv("mq.consoleAppender.enabled", "true") golang.ResetLogger() producer
") sk := os.Getenv("CLOUD_SDK_SK") projectId := "{project_id}" auth := basic.NewCredentialsBuilder().
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
