检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
修改用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交修改用户、客户端级别的流控任务，若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI PUT /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
使用控制台连接Kafka 本章节介绍Kafka实例如何在控制台生产消息。此功能通过将指定消息发送给Kafka实例，验证业务逻辑是否正常。 前提条件 仅在实例的“状态”为“运行中”时，才可以在Topic中生产消息。 已创建Topic。 在控制台生产消息 登录管理控制台。 在管理控制台左上角单击，选择区域。
records条消息，多数情况下客户端都会把一次消费到的数据处理完后才会开始下一次消费，如果单次消费的消息太多导致无法在max.poll.interval.ms时间内处理完或消息处理流程发生了异常（如需要写入后端数据库，后端数据库压力太大，慢SQL，时延增加等）导致消费时间增加，在max
Kafka实例批量删除消费组 功能介绍 该接口用于向Kafka实例批量删除消费组。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/groups/batch-delete 表1 路径参数 参数 是否必选
2023年7月15日前创建的Kafka实例，一个实例最多创建20个用户。2023年7月15日及以后创建的Kafka实例，一个实例最多创建500个用户。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/users 表1 路径参数
查询消息积压诊断报告列表 功能介绍 查询消息积压诊断报告列表 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks 表1 路径参数 参数 是否必选
修改实例配置 功能介绍 修改实例配置。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/configs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
消息积压诊断预检查 功能介绍 消息积压诊断预检查 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/instances/{instance_id}/diagnosis-check 表1 路径参数 参数 是否必选 参数类型 描述 project_id
查询用户列表 功能介绍 查询用户列表。 Kafka实例开启SASL功能时，才支持多用户管理的功能。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/users 表1 路径参数 参数 是否必选 参数类型
查询用户/客户端流控配置 功能介绍 该接口用于向Kafka实例查询流控的配置，若成功则返回流控配置的列表。 调用方法 请参见如何调用API。 URI GET /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota
查询维护时间窗时间段 功能介绍 查询维护时间窗开始时间和结束时间。 调用方法 请参见如何调用API。 URI GET /v2/instances/maintain-windows 请求参数 无 响应参数 状态码： 200 表1 响应Body参数 参数 参数类型 描述 maintain_windows
修改用户参数 功能介绍 修改用户参数 调用方法 请参见如何调用API。 URI PUT /v2/{engine}/{project_id}/instances/{instance_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 engine
生产失败。 数据量大的Topic进行分区平衡的时间会比较长，建议根据Topic的消费情况，适当调小Topic老化时间，使得Topic的部分历史数据被及时清理，加快迁移速度。Topic的数据量可以通过监控页面的“队列数据容量”查看，具体步骤请参考查看Kafka监控数据。 分区平衡前的准备工作
查询Topic的当前生产者列表 功能介绍 查询Topic的当前生产者列表 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers 表1 路径参数
Kafka生产消息 功能介绍 在控制台发送指定消息到Kafka实例 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/messages/action 表1 路径参数 参数 是否必选 参数类型 描述
List）权限管理，您可以在Topic中为不同的用户设置不同的生产消费消息的权限，以达到用户之间的权限隔离。 本章节主要介绍Kafka实例开启密文接入后，如何对Topic进行用户授权。 单机实例不支持设置Topic权限。 约束与限制 如果“allow.everyone.if.no.acl.fou
编辑消费组 功能介绍 编辑消费组 调用方法 请参见如何调用API。 URI PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String
操作。用户可以实时掌握实例的各类业务请求、资源占用、流量、连接数和消息积压等关键信息。 关于DMS for Kafka支持的监控指标，以及如何创建监控告警规则等内容，请参见支持的监控指标。 父主题： 安全
消息引擎的版本。取值支持1.1.0、2.3.0和2.7。 specification String 是 Kafka实例的基准带宽，表示单位时间内传送的最大数据量，单位MB。 取值范围为： 100MB 300MB 600MB 1200MB storage_space Integer 是 消息存储空间，单位GB。
批量添加或删除实例标签 功能介绍 批量添加或删除实例标签。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/{instance_id}/tags/action 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
