检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
values 参数 参数类型 描述 detail Array of detail objects 规格详情。 name String 实例类型。 unavailable_zones Array of strings 资源售罄的可用区列表。 available_zones Array of
createDMSInstanceOrderFailure 创建DMS实例任务执行失败 kafka createDMSInstanceTaskFailure 删除创建失败的DMS实例成功 kafka deleteDMSCreateFailureInstancesSuccess 删除创建失败的DMS实例失败
描述 private_plain_enable Boolean 实例是否支持内网PLAINTEXT访问接入方式。 true:实例支持内网PLAINTEXT访问方式接入方式。 false:实例不支持内网PLAINTEXT访问接入方式。 private_plain_address String
描述 private_plain_enable Boolean 实例是否支持内网PLAINTEXT访问接入方式。 true:实例支持内网PLAINTEXT访问方式接入方式。 false:实例不支持内网PLAINTEXT访问接入方式。 private_plain_address String
ExtendProductPropertiesEntity object 产品规格属性描述。 available_zones Array of strings 有可用资源的可用区列表。 unavailable_zones Array of strings 资源售罄的可用区列表。 表5 E
15消费进度提交失败 问题现象 Flink 1.15版本消费Kafka时, 消费进度提交失败,持续报错:COORDINATOR_NOT_AVAILABLE。 根因描述 Flink 1.15版本使用的Kafka客户端存在bug,当某次消费进度提交失败后, 客户端将coordinator置为不可用且无法自动恢复。
在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 URI GET /v1.0/availableZones 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/availableZones 响应消息 响应参数 参数说明见表1、表2。 表1 参数说明
说明 detail Array 规格详情。具体参数,请参见表5。 name String 实例类型。 unavailable_zones Array 资源售罄的可用区。 available_zones Array 有可用资源的可用区。 表5 Kafka实例的detail参数说明 参数
Kafka消息堆积了怎么办? 消息拉取失败的原因 更多 智能客服 您好!我是有问必答知识渊博的智能问答机器人,有问题欢迎随时求助哦! 社区求助 华为云社区是华为云用户的聚集地。这里有来自PaaS中间件的技术牛人,为您解决技术难题。
参数类型 描述 io_spec String 磁盘IO编码。 type String 磁盘类型。 available_zones Array of strings 可用区。 unavailable_zones Array of strings 不可用区。 表6 ListEngineS
Body = &model.UpdateInstanceReq{ MaintainEnd: &maintainEndUpdateInstanceReq, MaintainBegin: &maintainBeginUpdateInstanceReq, Description:
400 DMS.00400067 The available_zones parameter in the request must be an array that contains only one AZ ID. 请求参数available_zones非法,必须为只包含一个可用区ID的数组。
profile source ~/.profile 执行以下命令,获取demo需要的代码库。 #增加代理 export GOPROXY=https://goproxy.cn,direct #获取代码库 go get github.com/confluentinc/confluent-kafka-go/kafka
product_id 是 String 产品ID。 产品ID可以从查询产品规格列表获取。 maintain_begin 否 String 维护时间窗开始时间,格式为HH:mm。 maintain_end 否 String 维护时间窗结束时间,格式为HH:mm。 enable_publicip
实例创建成功后,跨VPC访问安全协议无法修改。 SASL PLAIN机制 - 未开启“SASL PLAIN机制”时,使用SCRAM-SHA-512机制对账号密码进行认证。 开启“SASL PLAIN机制”后,同时支持SCRAM-SHA-512机制和PLAIN机制,根据实际情况选择其中任意一种配置连接。
ShowSinkTaskDetailRequest request = new ShowSinkTaskDetailRequest(); request.withTopicInfo(ShowSinkTaskDetailRequest.TopicInfoEnum
"description": "instance description", "maintain_begin":"02:00:00", "maintain_end":"06:00:00" } 响应消息 响应参数 无。 响应样例 无。 状态码 操作成功的状态码如表3所示,其他响应见状态码。
##如果Kafka安全协议设置为“SASL_PLAINTEXT”,请注释以下参数。 context.verify_mode = ssl.CERT_REQUIRED ##证书文件,SSL证书参考“收集连接信息”章节获取。如果Kafka安全协议设置为“SASL_PLAINTEXT”,请注释以下参数。 context
kafka.v2.model.*; public class ShowInstanceTopicDetailSolution { public static void main(String[] args) { // The AK and SK used for
000000", "domain_id": "d78cbac1..........", "xdomain_id": "30086000........", "xdomain_type": "", "