启动已暂停的Smart Connect任务 功能介绍 启动已暂停的Smart Connect任务。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}
version String 参数解释: 服务端版本。 取值范围: 1.1.0 2.7 3.x register_time Long 参数解释: broker注册时间,为unix时间戳格式。 取值范围: 不涉及。
查询消费组信息 功能介绍 查询消费组信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 project_id
storage_resource_id String 参数解释: 存储资源ID。 取值范围: 不涉及。 storage_spec_code String 参数解释: IO规格。 取值范围: 不涉及。 service_type String 参数解释: 服务类型。
获取实例配置 功能介绍 获取实例配置。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/configs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID
查询Kafka产品规格核数 功能介绍 查询Kafka产品规格核数。 调用方法 请参见如何调用API。 URI GET /v2/kafka/products/cores 表1 Query参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 product_id
查询维护时间窗时间段 功能介绍 查询维护时间窗开始时间和结束时间。 调用方法 请参见如何调用API。 URI GET /v2/instances/maintain-windows 请求参数 无 响应参数 状态码:200 表1 响应Body参数 参数 参数类型 描述 maintain_windows
修改实例信息 功能介绍 修改实例信息。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目
修改所有消费组 功能介绍 修改所有消费组。 调用方法 请参见如何调用API。 URI PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String
修改转储任务的配额 功能介绍 修改转储任务的配额。 2022年9月前创建的实例支持调用此接口新增转储任务配额,2022年9月及以后创建的实例,转储任务配额默认为最大值,由于转储任务配额不支持减少,调用此接口修改转储任务配额会报错。 调用方法 请参见如何调用API。 URI PUT
查询可用区信息 当前页面API为历史版本API,未来可能停止维护。请使用查询可用区信息。 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 URI GET /v1.0/availableZones 请求消息 请求参数 无。 请求示例 GET https
取消Kafka消费组和Topic的订阅关系 消费者订阅Topic消费消息后,在消费组详情页可以查看消费进度。如果消费者不再消费某个Topic,您可以取消消费组和此Topic的订阅关系,避免由于此Topic的消息堆积,导致的告警误报。 约束与限制 已创建的1.1.0/2.3.0版本的
开启公网访问后,在哪查看公网IP地址? 在Kafka控制台,单击Kafka实例名称,进入实例详情页面。在“概览”页签,查看公网IP地址(即“公网连接地址”)。 如果您需要连接Kafka实例,请参考连接Kafka。 父主题: 连接问题
Kafka可以删除消费组下不用的Topic吗? 可以。在Kafka控制台的消费组详情页下,取消消费组和Topic的订阅关系,具体操作请参考取消Kafka消费组和Topic的订阅关系。 父主题: 消费组问题
消费者消费Topic失败,提示没有权限? 问题现象:同一个消费组内有多个消费者,为每个消费者授权不同的Topic访问权限,某一消费者消费其中一个Topic时,提示消费失败,报错信息如下:Not authorized to access topics。 问题原因:消费组的leader
Kafka Manager如何修改Topic的分区Leader? 在Kafka Manager中修改Topic的分区Leader的步骤如下: 登录Kafka Manager。 选择“Topic > List”,进入Topic列表页面。 单击待修改分区Leader的Topic名称(以
Kafka实例的SSL证书有效期多长? Kafka实例开启SASL_SSL时,需进行单向认证,证书有效期足够长(超过15年),客户端不需要关注证书过期风险。 查看SSL证书有效期的方法如下: 解压从Kafka实例控制台下载的压缩包,获取压缩包中的“phy_ca.crt”。 双击“phy_ca.crt
不同实例中,使用的SSL证书是否一样? Kafka实例中的SSL证书是通用的,不区分用户或者实例,即不同的用户或者实例,使用的SSL证书是同一个。 获取SSL证书的方法如下: 在Kafka控制台,单击实例名称,进入实例详情页。 在“连接信息 > SSL证书”所在行,单击“下载”。
扩容过程中涉及数据迁移吗? 扩容过程中不会迁移数据。 父主题: 实例规格变更问题
实例消费正常,为什么看不到消费者? 检查是否使用Flink进行消费。Flink使用的是assign模式,消费者定义在客户端,因此在Kafka实例控制台看不到消费者。 父主题: 消费组问题