-
修改Kafka实例Topic分区的副本 - 分布式消息服务Kafka版
修改Kafka实例Topic分区的副本 功能介绍 修改Kafka实例Topic分区的副本。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/r
-
创建实例 - 分布式消息服务Kafka版
String 虚拟私有云ID。 获取方法如下:登录虚拟私有云服务的控制台界面,在虚拟私有云的详情页面查找VPC ID。 security_group_id 是 String 指定实例所属的安全组。 获取方法如下:登录虚拟私有云服务的控制台界面,在安全组的详情页面查找安全组ID。 subnet_id
-
变更Kafka实例规格 - 分布式消息服务Kafka版
在实例列表页面,查看变更是否成功? 实例状态从“变更中”变为“运行中”时,表示变更成功,在“规格”中查看扩容后的带宽大小。 实例状态从“变更中”变为“变更失败”时,表示变更失败,把鼠标放在“变更失败”上,显示变更失败的原因。 实例状态为“变更失败”时,无法对实例进行重启、修改和删除等操作。等一段时间实例状
-
查询分区指定偏移量的消息 - 分布式消息服务Kafka版
查询分区指定偏移量的消息 功能介绍 查询分区指定偏移量的消息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions/{partition}/message
-
重置Manager密码 - 分布式消息服务Kafka版
重置Manager密码 功能介绍 重置Manager密码。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/kafka-manager-password 表1 路径参数 参数 是否必选 参数类型 描述
-
查询分区最新消息的位置 - 分布式消息服务Kafka版
查询分区最新消息的位置 功能介绍 查询分区最新消息的位置。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions/{partition}/end-message
-
查询用户权限 - 分布式消息服务Kafka版
查询用户权限 功能介绍 查询用户权限。 Kafka实例开启SASL功能时,才支持多用户管理的功能。 调用方法 请参见如何调用API。 URI GET /v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy
-
查询Kafka实例的协调器信息 - 分布式消息服务Kafka版
coordinators objects 所有消费组对应的协调器列表。 表3 coordinators 参数 参数类型 描述 group_id String 消费组ID。 id Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。
-
查询Smart Connect任务列表 - 分布式消息服务Kafka版
partition_format String 时间目录格式。(仅目标端类型为OBS时会显示) record_delimiter String 记录分行符。(仅目标端类型为OBS时会显示) store_keys Boolean 存储Key。(仅目标端类型为OBS时会显示) obs_part_size
-
创建消息积压诊断任务 - 分布式消息服务Kafka版
创建消息积压诊断任务 功能介绍 创建消息积压诊断任务 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks 表1 路径参数 参数 是否必选 参数类型
-
Kafka实例批量删除Topic - 分布式消息服务Kafka版
该接口用于向Kafka实例批量删除Topic。批量删除多个Topic时,部分删除成功,部分失败,此时接口返回删除成功,并在返回中显示删除失败的Topic信息。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/topics/delete
-
启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务 - 分布式消息服务Kafka版
Connect任务/重启已暂停或者运行中的Smart Connect任务 功能介绍 用于启动未启动的Smart Connect任务以及重启已暂停或者运行中的Smart Connect任务。注意,重启Smart Connect任务将重置同步进度,并重新开始同步任务。 调用方法 请参见如何调用API。 URI
-
创建关闭实例转储节点的订单 - 分布式消息服务Kafka版
请求Body参数 参数 是否必选 参数类型 描述 instance_id 是 String 需要关闭connector的实例id,和请求路径上的一致。 url 否 String 提交关闭connector订单后前端跳转的页面 响应参数 状态码: 200 表3 响应Body参数 参数
-
配置Kafka实例的公网访问 - 分布式消息服务Kafka版
在管理控制台左上角单击,选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。 单击Kafka实例的名称,进入实例的“基本信息”页面。 在“公网访问”后,单击,开启公网访问。在“
-
手动续费 - 分布式消息服务Kafka版
之前,您可以随时在Kafka控制台为Kafka实例续费,以延长Kafka实例的使用时间。 在云服务控制台续费 登录管理控制台。 单击左侧导航栏的图标,选择“应用中间件 > 分布式消息服务Kafka版”。 通过以下任意一种方法,为Kafka实例续费。 勾选Kafka实例名称左侧的方
-
查询Kafka实例Topic详细信息 - 分布式消息服务Kafka版
查询Kafka实例Topic详细信息 功能介绍 查询Kafka实例Topic详细信息。(单个实例调用不要超过1s一次) 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/topics/{topic}
-
查询消费组信息 - 分布式消息服务Kafka版
CompletingRebalance:所有成员加入group。 Stable:消费组内成员可正常消费。 coordinator_id Integer 协调器编号。 members Array of members objects 消费者列表。 group_message_offsets Array
-
关闭Kafka Manager - 分布式消息服务Kafka版
更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 执行成功 错误码 请参见错误码。 父主题: 实例管理
-
删除Smart Connector任务 - 分布式消息服务Kafka版
删除Smart Connector任务 功能介绍 删除Smart Connector任务。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}
-
开启或关闭实例自动创建topic功能 - 分布式消息服务Kafka版
开启或关闭实例自动创建topic功能 功能介绍 开启或关闭实例自动创建topic功能。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/autotopic 表1 路径参数 参数 是否必选 参数类型