检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"c3.medium.2", "arch_type" : "X86" } ], "name" : "cluster", "unavailable_zones" : [ "cn-north-7b", "cn-north-7a" ]
clientpublickey successfully imported. Entry for alias huaweiequipmentrootca successfully imported. Entry for alias huaweicloudca successfully imported
String 实例ID。 result String 操作结果：success、failed。 响应示例 { "results": [ { "result": "success", "instance": "
application/json X-Sdk-Date: 20240416T095341Z Authorization: SDK-HMAC-SHA256 Access=****************, SignedHeaders=content-type;host;x-sdk-date, Sign
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
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
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,
s时会显示） current_cluster_name String 当前Kafka实例别名。（仅源端类型为Kafka时会显示） cluster_name String 对端Kafka实例别名。（仅源端类型为Kafka时会显示） user_name String 对端Kafka用
exceptions import exceptions from huaweicloudsdkkafka.v2 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded
--group ${group-name} --members --describe 参数说明如下： connection-address：在Kafka控制台的“基本信息 > 连接信息”中，获取Kafka实例的连接地址。 group-name：消费组名称。 示例如下： [root@ecs-kafka
topic_other_configs 参数 是否必选 参数类型 描述 name 否 String 配置名称 value 否 String 配置值 响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 name String topic名称。 请求示例 创建一个Topic，Topic名称为test01。
{ "kafka_configs" : [ { "name" : "connections.max.idle.ms", "value" : "500000" }, { "name" : "log.retention.hours", "value"
instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 group_name 是 String 消费组名称 topic_name 是 String topic名称 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 report_id
exceptions import exceptions from huaweicloudsdkkafka.v2 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded
"hello world", "property_list" : [ { "name" : "KEY", "value" : "testKey" }, { "name" : "PARTITION", "value" : "0" } ] } 响应示例
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
