检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
CreateInstanceUserReq{ UserPasswd: &userPasswdCreateInstanceUserReq, UserName: &userNameCreateInstanceUserReq, } response, err := client.C
KMOffsetCache-dms-vm-fa3cf9d6-manager-shared-server-0 for generation 1", "groupId":"KMOffsetCache-dms-vm-fa3cf9d6-manager-shared-server-0", "coordinatorId":"0"
100GB。 当oper_type类型是horizontal时，每个broker的存储空间不变。 new_broker_num 否 Integer 当oper_type参数为horizontal时，该参数有效。 取值范围：最多支持30个broker。 new_product_id
CreateKafkaConsumerGroup(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API
BatchRestartOrDeleteInstanceReq body = new BatchRestartOrDeleteInstanceReq(); body.withAllFailure(BatchRestartOrDeleteInstanceReq.AllFailureEnum
描述 topic 是 String topic名称 brokers 否 Array of integers 分区平衡到的broker列表，自动生成分配方案时需指定该参数。 replication_factor 否 Integer 副本因子，自动生成分配方案时可指定。 assignment
分区分配策略。 表3 members参数说明 参数 类型 说明 host String 消费组consumer地址。 assignment Array of object assignment consumer分配到的分区信息。参数请参见表5。 member_id String 消费组consumer的ID。
&model.KafkaTopicQuota{ ConsumerByteRate: &consumerByteRateKafkaTopicQuota, ProducerByteRate: &producerByteRateKafkaTopicQuota, Topic: &
&model.KafkaTopicQuota{ ConsumerByteRate: &consumerByteRateKafkaTopicQuota, ProducerByteRate: &producerByteRateKafkaTopicQuota, Topic: &
&model.UpdateInstanceReq{ Description: &descriptionUpdateInstanceReq, Name: &nameUpdateInstanceReq, } response, err := client.UpdateInstance(request)
"policies" : [ { "owner" : false, "user_name" : "xxxa", "access_policy" : "pub" }, { "owner" : false, "user_name" : "root",
count Integer Topic流控数量 表4 KafkaTopicQuota 参数 参数类型 描述 topic String Topic名称 producer-byte-rate Integer 生产者速率 consumer-byte-rate Integer 消费者速率 请求示例
GetPlainSslEnableRequestSaslEnabledMechanismsEnum().PLAIN, } passWordPlainSslEnableRequest:= "password" userNamePlainSslEnableRequest:= "root"
若不再使用Kafka实例，您可以将他们删除，以免继续扣费。 您可以在“费用中心 > 总览”页面设置“可用额度预警”功能，当可用额度、通用代金券和现金券的总额度低于预警阈值时，系统自动发送短信和邮件提醒。当产生欠费后，请您及时充值使可用额度大于0。
record_delimiter String 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围： 逗号“,” 分号“;” 竖线“|” 换行符“\n” NULL 默认值：换行符“\n”。 deliver_time_interval Integer 根据用户配置的时间，周
Array of tasks objects 转储任务列表。 total_number Integer 转储任务总数。 max_tasks Integer 总的支持任务个数。 quota_tasks Integer 任务总数的配额。 表3 tasks 参数 参数类型 描述 task_id
response, err := client.DeleteConnectorTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
String 消息当前位点 message_log_start_offset Integer 消息开始位点 message_log_end_offset Integer 消息结束位点 consumer_id String 消费者Id host String host名称 client_id
false。 retention_time 否 Integer 参数解释： 消息老化时间。 约束限制： 不涉及。 取值范围： 1-720 默认取值： 72 topic_other_configs 否 Array of topic_other_configs objects 参数解释： Topic配置
record_delimiter 否 String 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围： 逗号“,” 分号“;” 竖线“|” 换行符“\n” NULL 默认值：换行符“\n”。 deliver_time_interval 是 Integer 根据用户配置的时间
