检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
response, err := client.ShowDiagnosisStack(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
max_offset Integer 参数解释: 最大偏移量。 取值范围: 不涉及。 min_offset Integer 参数解释: 最小偏移量。 取值范围: 不涉及。 brokers Array of brokers objects 参数解释: 代理。 表3 brokers 参数 参数类型
cluster", "storage_spec_code": "dms.physical.storage.high.v2", "broker_num": 1 } name:实例名称,由您自行定义。 engine:消息引擎,设置为reliability。 engine_version:消息引擎的版本。
response, err := client.DeleteBackgroundTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
MetadataDeleteReq body = new MetadataDeleteReq(); request.withBody(body); try { DeleteRocketMqMigrationTaskResponse
Integer 当oper_type类型是storage或horizontal时,该参数有效且必填,实例存储空间 = 代理数量 * 每个broker的存储空间。 当oper_type类型是storage时,代理数量不变,每个broker存储空间最少扩容100GB。 当oper_typ
build(); SendDlqMessageRequest request = new SendDlqMessageRequest(); request.withEngine(SendDlqMessageRequest.EngineEnum.fromValue("{engine}"));
Boolean 是否广播。 brokers Array of strings 关联的代理列表。 name String 消费组名称。 group_desc String 消费组描述。 retry_max_time Integer 最大重试次数。 permissions Array of
DeleteConsumerGroupRequest{} request.InstanceId = "{instance_id}" request.Group = "{group}" response, err := client.DeleteConsumerGroup(request)
默认取值: 不涉及。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 参数解释: 偏移量,表示从此偏移量开始查询。 约束限制: 不涉及。 取值范围: 大于等于0。 默认取值: 不涉及。 limit 否 Integer 参数解释: 查询数量。 约束限制:
NodeContextEntity 参数 参数类型 描述 id String ID broker_name String broker名称 broker_id Integer broker的ID address String 地址 public_address String 公网地址 请求示例
状态码:200 表2 响应Body参数 参数 参数类型 描述 total Number 总数。 next_offset Integer 下个分页的offset。 previous_offset Integer 上个分页的offset。 tags Array of TagEntity objects
不涉及。 默认取值: 不涉及。 表2 Query参数 参数 是否必选 参数类型 描述 limit 否 Integer 参数解释: 当次查询返回的最大个数。 约束限制: 不涉及。 取值范围: 1~50。 默认取值: 10。 offset 否 Integer 参数解释: 偏移量,表示从此偏移量开始查询。
&model.DeleteInstanceRequest{} request.InstanceId = "{instance_id}" response, err := client.DeleteInstance(request) if err == nil {
"brokers" : [ "broker-0" ], "createdAt" : 1709087952686, "permissions" : [ ], "retry_max_time" : 16, "consume_orderly" : false
response, err := client.ShowDiagnosisReport(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
nameTopicPerms:= "topic1" permTopicPerms:= model.GetUserTopicPermsPermEnum().PUB|SUB var listTopicPermsbody = []model.UserTopicPerms{
不涉及。 默认取值: 不涉及。 表2 Query参数 参数 是否必选 参数类型 描述 start 否 Integer 参数解释: 开启查询的任务编号。 约束限制: 不涉及。 取值范围: 大于等于0。 默认取值: 不涉及。 limit 否 Integer 参数解释: 查询数量。 约束限制:
RocketMQ社区发现漏洞并发布修复方案后,分布式消息服务RocketMQ版一般在1个月内进行修复,修复策略与社区保持一致。 操作系统紧急漏洞按照操作系统修复策略和流程对外发布,一般在一个月内提供修复方案,用户自行修复。 其他漏洞: 按照版本正常升级流程解决。 修复声明 为了防止客
审计与日志 云审计服务(Cloud Trace Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后,CTS可记录DMS