检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
后的代理个数,单击“下一步”。确认扩容信息无误后,单击“提交”。 在实例列表页面的“规格”中查看扩容后的代理个数。 扩容代理个数前,需确认安全组已放通的网段和实例对外提供的端口信息,否则可能造成客户端无法连接新扩容的业务节点,从而导致消息生产失败。其中,放通的网段为实例所在子网网
标签管理 批量添加或删除实例标签 查询实例标签 查询项目标签 父主题: API V2(推荐)
入消息通知服务中,创建主题和添加订阅。创建完成后,返回“创建告警规则”页面,在“通知对象”后单击,然后选择创建的告警通知主题。 在添加订阅后,对应的订阅终端会收到订阅通知,用户要选择确认订阅,后续才能收到告警信息。 图6 创建告警通知主题 图7 添加订阅 生效时间:该告警规则仅在生效时间内发送通知消息。
最大重试次数 是否允许以广播模式消费 是否顺序消费 group-01 16 否 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。
在此处重新为用户设置。管理员默认具有所有权限,无需手动添加。 5.x基础版不支持此操作。 单击用户名称,进入用户详情页面。 在“Topic权限”/“消费组权限”页签中,单击“添加权限”,弹出“添加权限”对话框。 勾选需要添加权限的Topic或者消费组,选择所需的特殊权限,单击“确定”。
基本概念 账号 用户注册账号时,账号对其所拥有的资源及云服务具有完全的访问权限,可以重置用户密码、分配用户权限等。由于账号是付费主体,为了确保账号安全,建议您不要直接使用账号进行日常管理工作,而是创建用户并使用他们进行日常管理工作。 用户 由账号在IAM中创建的用户,是云服务的使用人员,具有身份凭证(密码和访问密钥)。
包括新建元数据迁移任务、查询实例下所有迁移任务或查询指定迁移任务信息、删除元数据迁移任务。 参数管理 包括修改RocketMQ配置。 标签管理 包括添加或删除实例标签、查询实例标签和查询项目标签。 其他接口 包括查询可用区信息。 规格变更管理 包括查询实例的扩容规格列表和实例规格变更。 实例管理
2023-04-21 本次变更如下: 新增查询消费者列表接口。 2023-02-17 本次变更如下: 更新创建实例的URI。 新增批量添加或删除实例标签、查询实例标签和查询项目标签接口。 2023-01-13 本次变更如下: 新增查询主题列表接口。 2022-07-07 本次变更如下:
最大重试次数 是否允许以广播模式消费 group-01 broker-0 16 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。
0,获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq
修改读队列个数或写队列个数。 读队列个数:Topic读数据可用的总队列数。 写队列个数:Topic写数据可用的总队列数。 创建Topic时未关联所有代理,单击“添加关联代理”,将Topic分布到其他代理上,并设置读队列个数和写队列个数。 描述 Topic的描述信息。 取值长度为0~200个字符。 修改完成后,单击“确定”。
职能定义权限的粗粒度授权机制。策略以API接口为粒度进行权限拆分,授权更加精细,可以精确到某个操作、资源和条件,能够满足企业对权限最小化的安全管控要求。 如果您要允许或是禁止某个接口的操作权限,请使用策略。 账号具备所有接口的调用权限,如果使用账号下的IAM用户发起API请求时,
0,获取librocketmq库。 将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq
中快速识别出业务感兴趣的数据将会显得尤为重要。分布式消息服务RocketMQ版提供的消息过滤的能力,可以完好的支持该场景,终端写入时为消息添加标签,指定该消息的类型,业务端消费时则可以指定只消费特定类型的标签,从而实现更好的业务处理。
行签名,签名过程会自动往请求中添加Authorization(签名认证信息)和X-Sdk-Date(请求发送的时间)请求头。 AK/SK认证的详细说明请参见认证鉴权的“AK/SK认证”。 对于管理员创建IAM用户接口,使用AK/SK方式认证时,添加消息头后的请求如下所示。 POST
返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 在“go.mod”中增加以下代码,添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache
Topic的权限,包括发布+订阅、发布和订阅。 关联代理 选择在某个代理上创建Topic,并设置Topic的队列个数。 如果实例部署在多个代理上,单击“添加关联代理”,可以在其他代理上创建Topic,并设置Topic的队列个数。 如果需要新增关联代理,则需要先扩容代理个数,具体操作请参见变更R
返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 在“go.mod”中增加以下代码,添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache
如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go.mod”,并增加以下代码,添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache
如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go.mod”,并增加以下代码,添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache