检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Topic管理 查看RocketMQ Topic详情 修改RocketMQ Topic配置 删除RocketMQ Topic 父主题: 配置Topic
管理消费组 创建RocketMQ消费组 查看RocketMQ消费组详情 查看RocketMQ消费者连接地址 修改RocketMQ消费组配置 重置RocketMQ消费进度 删除RocketMQ消费组
Array of strings 关联的代理(仅RocketMQ实例4.8.0版本需要填写此参数)。 queue_num 否 Number 队列数,范围1~50。 queues 否 Array of queues objects 队列(仅RocketMQ实例4.8.0版本需要填写此参数)。
以下示例仅介绍同步发送的示例代码。 收发普通消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发普通消息前,需要确保Topic的消息类型为“普通”。 RocketMQ TCP协议的Python SDK只支持Linux系统。
状态码是一组从1xx到5xx的数字代码,状态码表示了请求响应的状态,完整的状态码列表请参见状态码。 对于管理员创建IAM用户接口,如果调用后返回状态码为“201”,则表示请求成功。 响应消息头 对应请求消息头,响应同样也有消息头,如“Content-type”。 对于管理员创建IAM用户接口,返回如图1所示的消息头。
短时间内生产、消费消息请求数量过多。 秒级突发流量过大时,可能出现该秒请求被流控。 监控数据采集的是一分钟内平均TPS,不是秒级监控。 当请求被流控时,会导致生产消息请求失败,且服务端返回215错误码。为避免出现流控情况,请确保生产、消费TPS在给定实例规格内。 父主题: 监控告警问题
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询单个主题成功。 错误码 请参见错误码。 父主题:
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 批量修改消费组成功。 错误码 请参见错误码。 父主题:
rabbitmqInstance表示RabbitMQ实例配额。 kafkaInstance表示Kafka实例配额。 rocketmqInstance表示RocketMQ实例配额。 tags表示标签的配额。 quota Integer 租户最大可以创建的实例个数,或者每个实例最大可以创建的标签个数。 used Integer
C/PCI等)的安全合规认证,用户可自行申请下载合规资质证书。 图1 合规证书下载 资源中心 华为云还提供以下资源来帮助用户满足合规性要求,具体请查看资源中心。 图2 资源中心 销售许可证&软件著作权证书 另外,华为云还提供了以下销售许可证及软件著作权证书,供用户下载和参考。具体请查看合规资质证书。
Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 topic1:表示Topic名称。 异步发送 异步发送是指消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息的通讯方式。 使用异步发送
of strings 待删除的消费组列表。 name 否 String 消费组名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。 brokers 否 Array of strings 关联的代理列表(仅RocketMQ实例4.8.0版本需要填写此参数)。
消息问题 RocketMQ的消息保留时间是多少?可以修改吗? RocketMQ支持的最大消息大小是多少?可以修改吗? RocketMQ副本存储形式是怎样的?可以修改吗? 消息创建时间在哪设置?
参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 topic 是 String 主题名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 read_queue_num
Topic问题 支持多少个Topic? 是否支持自动创建Topic? Topic名称的命名规则是什么?
Topic管理 创建主题或批量删除主题 查询主题列表 删除指定主题 查询单个主题 修改主题 查询主题消费组列表 查询主题的消息数 父主题: API V2(推荐)
消费组问题 支持多少个消费组个数? 为什么查询到的消费组不在控制台中?
String 消息ID。 instance_id String 实例ID。 topic String 主题名称。 store_timestamp Number 存储消息的时间。 born_timestamp Number 产生消息的时间。 reconsume_times Integer 重试次数。
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 204 操作成功。 错误码 请参见错误码。 父主题: Topic管理
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 204 操作成功。 错误码 请参见错误码。 父主题: 消费组管理