检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
详情页面。 在左侧导航栏,单击“消息查询”,进入“消息查询”页面。 在页面顶部设置查询条件,查询待重新发送的消息。 在待重新发送的消息所在行,单击“消费验证”,弹出“消费验证”对话框。 参考表1,设置消费验证参数。 表1 消费验证参数说明 参数 说明 Group ID 选择待进行消费验证的消费组名称。
= Producer(gid) producer.set_name_server_address(name_srv) # 设置权限(角色名和密钥) producer.set_session_credentials( "ROCKETMQ_AK"
[]byte("this is a message : " + strconv.Itoa(i)), } // 设置消息的Key和Tag msg.SetKeys("a", "b") msg.SetTag("ab")
[]byte("this is a message : " + strconv.Itoa(i)), } // 设置消息的Key和Tag msg.SetKeys("a", "b") msg.SetTag("ab")
RocketMQ Kafka RabbitMQ 优先级队列 不支持 不支持 3.8.35版本:支持。建议优先级大小设置在0-10之间。 AMQP-0-9-1版本:支持。优先级大小设置在1-9之间。 延迟队列 支持 不支持 3.8.35版本:不支持。 AMQP-0-9-1版本:支持。 死信队列
Topic的权限,包括发布+订阅、发布和订阅。 关联代理 选择在某个代理上创建Topic,并设置Topic的队列个数。 如果实例部署在多个代理上,单击“添加关联代理”,可以在其他代理上创建Topic,并设置Topic的队列个数。 如果需要新增关联代理,则需要先扩容代理个数,具体操作请参见变
如果您持有多台到期日不同的RocketMQ实例,可以将到期日统一设置到一个日期,便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源,同时续费一个月,并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。 父主题: 续费
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。当业务不再使用公网访问功能时,关闭实例的公网访问功能。 约束与限制 RocketMQ实例只支持绑定IPv4弹性IP地址。 前提条件 只有处于“运行中”状态
单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,选择“元数据迁移”,进入迁移任务列表页面。 单击“创建迁移任务”,弹出“创建迁移任务”对话框。 参考表1,设置迁移任务的参数。 表1 迁移任务参数说明 参数 说明 任务类型 选择“RabbitMQ到RocketMQ元数据迁移”。 任务名称 您可以自
审计与日志 云审计服务(Cloud Trace Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后,CTS可记录DMS
Management,简称IAM),支持三种身份认证方式:用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。 访问控制 对企业中的员工设置不同的DMS for RocketMQ访问权限,以达到不同员工之间的权限隔离,使用IAM进行精细的权限管理。该服务提供用户身份认证、权限分
客户端数 定时/延时消息 事务消息 顺序消息 Min(单客户端线程数 * 客户端数,队列数) 单客户端线程数的调整需谨慎,不能盲目调大线程数,如果设置过大的线程数反而会带来大量的线程切换开销。 理想环境下单客户端的最优线程数计算模型为:C *(T1+T2)/T1。 其中,C为单机vCPU
选择“明细账单”,在筛选条件中选择“资源ID”,并输入3复制的资源ID,按“Enter”即可搜索该资源的账单。 图3 查询资源账单 这里设置的统计维度为“按使用量”,统计周期为“按账期”,您也可以设置其他统计维度和周期,详细介绍请参见流水与明细账单。
Non-kafka queues do not support retention_hours. 非Kafka队列不能设置消息保存时间。 请检查是否是kafka队列,如果不是请不要设置消息保存时间 400 DMS.10240032 The queue is being created. 队列正在创建。
享版页面。 在左侧导航栏选择“回收站”,进入“回收站”页面。 单击“回收站策略”,弹出“回收站策略”对话框。 开启启用回收站,并设置保留天数(只能设置为1~7天),单击“确定”。 修改保留天数仅对修改后删除的实例生效,修改前已在回收站中的实例依然按照修改前的天数保留实例。 恢复RocketMQ实例
broker_cpu_core_load CPU核均负载 该指标用于统计节点虚拟机CPU每个核的平均负载 >0 RocketMQ实例节点 1分钟 broker_disk_usage 磁盘容量使用率 该指标用于统计节点虚拟机的磁盘容量使用率 单位:% 0~100 RocketMQ实例节点 1分钟
扩容存储空间或代理个数 公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 支持区域: 全部 设置实例公网访问 消息查询 通过查询消息功能查看具体的消息内容,以及确定消息是否生产/消费成功。
type String 产品类型,single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code String CBC的规格码。 arch_types Array of
数。 写队列个数:Topic写数据可用的总队列数。 创建Topic时未关联所有代理,单击“添加关联代理”,将Topic分布到其他代理上,并设置读队列个数和写队列个数。 描述 Topic的描述信息。 取值长度为0~200个字符。 修改完成后,单击“确定”。 父主题: Topic管理
在左侧导航栏,单击“消费组管理”,进入消费组列表页面。 在待重置消费进度的消费组所在行,单击“重置消费进度”,弹出“重置消费进度”对话框。 参考表1,设置重置消费进度参数。 表1 重置消费进度参数说明 参数 说明 Topic名称 选择待重置消费进度的Topic。 时间 选择重置消费进度的时间点,重置完成后,将从此时间点开始消费。