-
查询消费组信息 - 分布式消息服务Kafka版
表4 members 参数 参数类型 描述 host String 消费组consumer地址。 assignment Array of assignment objects consumer分配到的分区信息。 member_id String 消费组consumer的ID。
-
删除Smart Connector任务 - 分布式消息服务Kafka版
= client.DeleteConnectorTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }
-
暂停Smart Connect任务 - 分布式消息服务Kafka版
更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
启动已暂停的Smart Connect任务 - 分布式消息服务Kafka版
= client.ResumeConnectorTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }
-
查询实例标签 - 分布式消息服务Kafka版
if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的
-
删除用户/客户端流控配置 - 分布式消息服务Kafka版
&userDefaultDeleteKafkaUserClientQuotaTaskReq, Client: &clientDeleteKafkaUserClientQuotaTaskReq, User: &userDeleteKafkaUserClientQuotaTaskReq
-
创建用户/客户端流控配置 - 分布式消息服务Kafka版
"" request.Body = &model.CreateKafkaUserClientQuotaTaskReq{ ConsumerByteRate: &consumerByteRateCreateKafkaUserClientQuotaTaskReq, ProducerByteRate
-
查询项目标签 - 分布式消息服务Kafka版
fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
Kafka实例查询Topic - 分布式消息服务Kafka版
replication Integer 副本数,配置数据的可靠性。 partition Integer topic分区数,设置消费的并发数。 retention_time Integer 消息老化时间。
-
查询后台任务管理中的指定记录 - 分布式消息服务Kafka版
user_name String 用户名。 user_id String 用户ID。 params String 任务参数。 status String 任务状态。 created_at String 启动时间。 updated_at String 结束时间。
-
查询维护时间窗时间段 - 分布式消息服务Kafka版
("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
Go - 分布式消息服务Kafka版
{ "bootstrap.servers": brokers, } producer, err := kafka.NewProducer(config) if err !
-
删除指定的实例 - 分布式消息服务Kafka版
) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签
-
重置密码 - 分布式消息服务Kafka版
) print(e.error_msg) 重置密码。
-
修改用户/客户端流控配置 - 分布式消息服务Kafka版
"" request.Body = &model.UpdateKafkaUserClientQuotaTaskReq{ ConsumerByteRate: &consumerByteRateUpdateKafkaUserClientQuotaTaskReq, ProducerByteRate
-
获取实例配置 - 分布式消息服务Kafka版
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer
-
查询用户/客户端流控配置 - 分布式消息服务Kafka版
表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量,表示查询该偏移量后面的记录。 limit 否 Integer 查询返回记录的数量限制。
-
查询所有消费组 - 分布式消息服务Kafka版
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer
-
查询Topic的当前生产者列表 - 分布式消息服务Kafka版
响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 total Integer 总条数 producers Array of producers objects 生产者列表 表4 producers 参数 参数类型 描述 producer_address String
-
修改Kafka Topic分区数 - 分布式消息服务Kafka版
/config/ssl-user-config.properties 父主题: Topic管理