检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"ecs_flavor_id": "c3ne.2xlarge.2" }], "name": "cluster", "unavailable_zones": [] }] }], "Monthly": [{ "name": "kafka", "version": "XXX",
"c3.medium.2", "arch_type" : "X86" } ], "name" : "cluster", "unavailable_zones" : [ "cn-north-7b", "cn-north-7a" ]
s时会显示） current_cluster_name String 当前Kafka实例别名。（仅源端类型为Kafka时会显示） cluster_name String 对端Kafka实例别名。（仅源端类型为Kafka时会显示） user_name String 对端Kafka用
"product_alias" : "kafka.2u4g.cluster" } }, { "type" : "cluster", "product_id" : "c6.4u8g.cluster", "ecs_flavor_id" : "c6.xlarge
Topic名称 success Boolean 是否删除成功。 响应示例 { "topics" : [{ "id" : "haha", "success" : true }, { "id" : "aabb", "success" :
1.0", "2.7" ], "products" : [ { "type" : "cluster", "product_id" : "c6.2u4g.cluster", "ecs_flavor_id" : "c3.large.2", "arch_types"
of topics objects Topic列表。 表4 topics 参数 参数类型 描述 id String Topic名称。 success Boolean 是否删除成功。 请求示例 批量删除Topic。 POST https://{endpoint}/v2/{projec
application/json X-Sdk-Date: 20240416T095341Z Authorization: SDK-HMAC-SHA256 Access=****************, SignedHeaders=content-type;host;x-sdk-date, Sign
Country Name (2 letter code) [XX]:xx State or Province Name (full name) []:js Locality Name (eg, city) [Default City]:nj Organization Name (eg,
Array of InstanceConfig objects kafka配置列表。 表3 InstanceConfig 参数 参数类型 描述 name String 配置名称。 valid_values String 有效值。 default_value String 默认值。 config_type
'topic_name': 'topic-name', 'consumer_id': 'consumer-id' } print('start consumer') consumer = KafkaConsumer(conf['topic_name'],
Country Name (2 letter code) [XX]:xx State or Province Name (full name) []:js Locality Name (eg, city) [Default City]:nj Organization Name (eg,
String 实例ID。 result String 操作结果：success、failed。 响应示例 { "results": [ { "result": "success", "instance": "
exceptions import exceptions from huaweicloudsdkkafka.v2 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded
instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 group_name 是 String 消费组名称 topic_name 是 String topic名称 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 report_id
topic_other_configs 参数 是否必选 参数类型 描述 name 否 String 配置名称 value 否 String 配置值 响应参数 状态码：200 表4 响应Body参数 参数 参数类型 描述 name String topic名称。 请求示例 创建一个Topic，Topic名称为test01。
s时会显示） current_cluster_name String 当前Kafka实例别名。（仅源端类型为Kafka时会显示） cluster_name String 对端Kafka实例别名。（仅源端类型为Kafka时会显示） user_name String 对端Kafka用
"hello world", "property_list" : [ { "name" : "KEY", "value" : "testKey" }, { "name" : "PARTITION", "value" : "0" } ] } 响应示例
{ "kafka_configs" : [ { "name" : "connections.max.idle.ms", "value" : "500000" }, { "name" : "log.retention.hours", "value"
available_zones参数说明 参数 类型 说明 soldOut Boolean 是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
