检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
es/{instance_id}/management/groups/{group} 响应示例 状态码: 200 查询实例集群的消费组信息成功。 { "group" : { "members" : [ { "host" : "/172.31.1.102",
d}/instances/{instance_id}/management/topics/{topic} 响应示例 状态码: 200 查询成功。 { "topic" : "test", "partitions" : [ { "partition" : 0,
project_id}/instances/{instance_id}/topics/diskusage 响应示例 状态码: 200 查询成功。 { "broker_list" : [ { "broker_name" : "broker-0", "data_disk_size"
创建用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交创建用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI POST /v2/kafka/{project_id}/instances/{instance_id}
删除用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交删除用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI DELETE /v2/kafka/{project_id}/instances/{instance_i
id}/instances/{instance_id}/topics?offset=0&limit=10 响应示例 状态码: 200 查询成功。 { "total" : 1, "size" : 0, "topics" : [ { "policiesOnly" :
GET https://{endpoint}/v2/{project_id}/kafka/tags 响应示例 状态码: 200 查询项目标签成功。 { "tags" : [ { "key" : "key1", "values" : [ "value-test",
nce_id}/management/topics/{topic}/messages 响应示例 状态码: 200 查询分区指定时间段的消息成功。 { "messages" : [ { "topic" : "mytest", "partition" : 0,
统快速响应的目的。 如网站的用户注册场景,在用户注册成功后,还需要发送注册邮件与注册短信,这两个流程使用Kafka消息服务通知邮件发送系统与短信发送系统,从而提升注册流程的响应速度。 图1 串行发送注册邮件与短信流程 图2 借助消息队列异步发送注册邮件与短信流程 错峰流控与流量削峰
"group_ids" : [ "get-sync-group0", "get-sync-group1" ] } 响应示例 状态码: 200 删除消费组成功。 { "failed_groups" : [ { "group_id" : "test-1", "error_message"
在“定时任务”页签中,查看升级任务是否开始执行。 当“状态”为“待执行”时,表示升级任务未执行。 当“状态”为“成功”时,表示升级任务开始执行。 在“后台任务”页签中,查看升级任务的状态。 当任务的“状态”为“成功”时,表示升级完成。 当任务的“状态”为“失败”时,表示升级失败,请联系客服处理。 修改定时升级任务
"throttle" : 10000000, "time_estimate" : false } 响应示例 状态码: 200 提交重平衡任务成功(若为预估时间任务则返回预估时间)。 { "job_id" : "8a2c259182ab0e9d0182ab1882560009",
"0e35a9f4-e75d-4fd6-b230-280860f666f7" ] } 响应示例 状态码: 200 批量删除消息积压诊断报告成功 { "results" : [ { "result" : "true", "id" : "0e35a9f4-e75d
https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags 响应示例 状态码: 200 查询实例标签成功。 { "tags" : [ { "key" : "key1", "value" : "value1" }, {
Kafka实例的连通性。 显示“连通性检测成功”时,表示两端Kafka实例可以正常连接。 单击“立即创建”,跳转到Smart Connect任务列表页面,页面右上角显示“创建xxx任务成功”。 Kafka数据复制的Smart Connect任务创建成功后,Kafka会自动创建以下Topic。
Redis实例地址。(仅源端类型为Redis时会显示) redis_type String Redis实例类型。(仅源端类型为Redis时会显示) dcs_instance_id String DCS实例ID。(仅源端类型为Redis时会显示) sync_mode String 同步类
https://{endpoint}/v2/{project_id}/instances/{instance_id}/configs 响应示例 状态码: 200 获取实例配置成功。 { "kafka_configs" : [ { "name" : "min.insync.replicas", "valid_values"
修改用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交修改用户、客户端级别的流控任务,若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI PUT /v2/kafka/{project_id}/instances/{instance_id}/
oject_id}/connectors/{connector_id}/sink-tasks 响应示例 状态码: 200 查询转储任务列表成功。 { "tasks" : [ { "task_id" : "2e148bed-3038-4617-8ade-b52e84a33eeb"
/message-diagnosis-tasks?offset=1&limit=10 响应示例 状态码: 200 查询消息积压诊断报告列表成功 { "report_list" : [ { "report_id" : "89b202d5-1f34-4a89-af9d-698496d0b7b1"