检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用Admin Tool连接RocketMQ实例查询消费组信息时，会查出一些控制台中没有配置的消费组，如CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_ONSAPI_PERMISSION、CID_ON
查询主题列表 功能介绍 该接口用于查询指定RocketMQ实例的Topic列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id
实例名称支持自定义，但需要符合命名规则：长度为4~64个字符，由英文字母开头，只能由英文字母、数字、中划线、下划线组成。 此处配置为“rocketmq-test”。 企业项目 该参数针对企业用户使用。企业项目是对企业不同项目间资源的分组和管理，属于逻辑隔离。 此处选择“default”。 ACL访问控制
数据迁移任务接口。 2023-04-21 本次变更如下： 新增查询消费者列表接口。 2023-02-17 本次变更如下： 更新创建实例的URI。 新增批量添加或删除实例标签、查询实例标签和查询项目标签接口。 2023-01-13 本次变更如下： 新增查询主题列表接口。 2022-07-07
API V1 实例管理类接口 其他接口 父主题： 历史API
文字符必须为UTF-8编码。 每个接口的请求消息体内容不同，也并不是每个接口都需要有请求消息体（或者说消息体为空），GET、DELETE操作类型的接口就不需要消息体，消息体具体内容需要根据具体接口而定。 对于管理员创建IAM用户接口，您可以从接口的请求部分看到所需的请求参数及参数
响应Body参数 参数 参数类型 描述 job_id String 任务ID。 请求示例 批量修改消费组的参数，将consumer-group-test消费组的最大重试次数修改为16。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups
创建实例 功能介绍 创建实例，该接口支持创建按需和包周期两种计费方式的实例。 调用方法 请参见如何调用API。 URI POST /v2/{engine}/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String
"topicName" : "topic-test1", "topicSysFlag" : 0, "writeQueueNums" : 3 } }, "subscriptionGroupTable" : { "group-test1" : {
获取账号名和账号ID 在调用接口的时候，部分URL中需要填入账号名和账号ID，所以需要先在管理控制台上获取到账号名和账号ID。账号名和账号ID获取步骤如下： 登录管理控制台。 鼠标悬停在右上角的用户名，选择下拉列表中的“我的凭证”。 查看账号名和账号ID。 图1 查看账号名和账号ID
} } } } 获取Token后，再调用其他接口时，您需要在请求消息头中添加“X-Auth-Token”，其值即为Token。例如Token值为“ABCDEFJ....”，则调用接口时将“X-Auth-Token: ABCDEFJ....”加到请求消息头即可，如下所示。
SELF_TEST_TOPIC OFFSET_MOVED_EVENT Topic名称不能设置为相同，否则会创建失败。 创建Topic后不能修改名称。 如果Topic名称中包含“%”或“|”，在云监控中会将“%”或“|”转换为“_”显示，例如Topic名称为“test%01”，在
通过Topic和Tag实现消息分类 方案概述 Topic是消息关联的基础逻辑单元，消息的生产与消费围绕着Topic进行。每个Topic包含若干条消息，每条消息只能属于一个Topic。 Tag是消息的标签，用于在同一Topic下区分不同类型的消息。来自同一业务单元的消息，可以根据不
删除消费组consumer-group-test。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups?action=delete { "groups" : [ "consumer-group-test" ] } 响应示例
API概览 表1 实例管理类接口 API 说明 生命周期管理 包括创建实例、修改实例信息、查询实例、删除实例、查询代理列表。 消费组管理 包括查询消费组、创建消费组、删除消费组、修改消费组、查询消费列表或详情、重置消费进度。 Topic管理 包括创建主题、删除主题、查询主题、修改
API V2（推荐） 生命周期管理 消费组管理 Topic管理 消息管理 用户管理 元数据迁移 参数管理 标签管理 其他接口 规格变更管理 实例管理
pics { "name" : "topic-test", "message_type" : "NORMAL" } 响应示例 状态码： 200 创建主题或批量删除主题成功。 { "id" : "topic-test" } SDK代码示例 SDK代码示例如下。 Java
Printf("start producer error: %s", err.Error()) os.Exit(1) } topic := "test" for i := 0; i < 100; i++ { msg := &primitive.Message{ Topic:
rocketmq.client import Producer, Message topic = 'TopicTest' gid = 'test' name_srv = '192.168.0.1:8100' def create_message(): msg = Message(topic)
ect_id}/instances/{instance_id}/messages/resend { "group" : "GID_test", "client_id" : "192.168.0.1", "msg_id_list" : [ "id1" ] } 响应示例
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
