检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
重置Manager密码 功能介绍 重置Manager密码。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/kafka-manager-password 表1 路径参数 参数 是否必选 参数类型 描述
暂停Smart Connect任务 功能介绍 暂停Smart Connect任务。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause 表1
启动已暂停的Smart Connect任务 功能介绍 启动已暂停的Smart Connect任务。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume
Connect任务以及重启已暂停或者运行中的Smart Connect任务。注意，重启Smart Connect任务将重置同步进度，并重新开始同步任务。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/kafka/instances/{instance_id}/connect
> 连接信息”中，获取Kafka实例的连接地址。 topic-name：Topic名称。 number-of-partitions：Topic的分区数。出于性能考虑，建议单个Topic的分区数设置为200以内。 示例如下： [root@ecs-kafka bin]# ./kafka-topics
Connect，提交创建Smart Connect节点任务。 当前通过调用API，只支持按需实例创建Smart Connect节点。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/connector 表1
该接口用于向Kafka实例批量删除Topic。批量删除多个Topic时，部分删除成功，部分失败，此时接口返回删除成功，并在返回中显示删除失败的Topic信息。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/topics/delete
创建消息积压诊断任务 功能介绍 创建消息积压诊断任务 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks 表1 路径参数 参数 是否必选 参数类型
创建关闭实例转储节点的订单。 当前页面API为历史版本API，未来可能停止维护。请使用关闭Smart Connect（按需实例）。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/instances/{instance_id}/delete-connector-order
关闭Kafka Manager 功能介绍 关闭Kafka Manager，相应的原来开放出的management相关接口也将不可用。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/kafka/instances/{instance_id}/management
删除Smart Connector任务 功能介绍 删除Smart Connector任务。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}
开启或关闭实例自动创建topic功能 功能介绍 开启或关闭实例自动创建topic功能。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/autotopic 表1 路径参数 参数 是否必选 参数类型
修改指定消费组 功能介绍 修改指定消费组。 调用方法 请参见如何调用API。 URI PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 engine
重启Manager 功能介绍 重启Manager。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/restart-kafka-manager 表1 路径参数 参数 是否必选 参数类型 描述 project_id
消息积压诊断预检查 功能介绍 消息积压诊断预检查 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/instances/{instance_id}/diagnosis-check 表1 路径参数 参数 是否必选 参数类型 描述 project_id
表1提供了分布式消息服务Kafka版支持的SDK列表，您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。 表1 SDK列表 编程语言 Github地址 参考文档 Java huaweicloud-sdk-java-v3 Java SDK使用指导 Python
前提条件 已准备一台Linux系统的服务器，并安装Java Development Kit 1.8.111或以上版本，配置JAVA_HOME与PATH环境变量。 实例已开启Kafka SASL_SSL。 步骤一：制作证书 登录Linux系统的服务器，执行以下命令，生成server.keystore
获取SK的方法，具体请参见新增访问密钥。 转储地址 设置存储Topic数据的OBS桶的名称。 选择：在下拉列表中选择已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。 输入：输入已创建的OBS桶名称，或者单击“创建转储地址”，新创建一个OBS桶。输入的OBS桶必须和Kafka实例在同一个区域。
删除后台任务管理中的指定记录 功能介绍 删除后台任务管理中的指定记录。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id}/tasks/{task_id} 表1 路径参数 参数 是否必选 参数类型
删除指定的实例 功能介绍 删除指定的实例，释放该实例的所有资源。 调用方法 请参见如何调用API。 URI DELETE /v2/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
