检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
查询配额 功能介绍 查询配额详情。 当前页面API为历史版本API，未来可能停止维护。 调用方法 请参见如何调用API。 URI GET /v1.0/{project_id}/quotas/dms 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
实例升级 功能介绍 实例内核升级 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/kafka/instances/{instance_id}/upgrade 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
消费消息。 密文接入信息 如果实例开启密文接入，则需要获得连接实例的用户名与密码、SASL认证机制和Kafka安全协议。Kafka安全协议设置为“SASL_SSL”时，还需要获取SSL证书。 连接实例的用户名在Kafka实例控制台的“用户管理”页面中查看，如果忘记密码，可通过重置密码重新获得。
y 参数 参数类型 描述 type String 实例类型。 product_id String 产品ID。 ecs_flavor_id String 该产品使用的ECS规格。 arch_types Array of strings 支持的CPU架构类型。 charging_mode
查询指定消费组的topic 功能介绍 查询指定消费组的topic。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/topics 表1 路径参数 参数
查询消费组消息位点 功能介绍 查询消费组消息位点。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/message-offset 表1 路径参数 参数
）和空格，并且不能以-开头 vpc_id 是 String 虚拟私有云ID。 获取方法如下：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。 security_group_id 是 String 指定实例所属的安全组。 获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。
Kafka单机实例Topic数量计算 Kafka实例对Topic分区数之和设置了上限，当达到上限之后，用户无法继续创建Topic。 所以，Topic数量和实例分区数上限、每个Topic的分区数有关，其中，每个Topic分区数可在创建Topic时设置，实例分区数上限参考表1。 kafka.2u4g.single实例的分区数上限为250。
topic分区数，设置消费的并发数。 默认值为3，取值范围为1~100。 replication Integer 否 副本数，配置数据的可靠性 默认值为3，取值范围为1~3。 sync_replication Boolean 否 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效。
查询指定消费组的消费成员 功能介绍 查询指定消费组的消费成员。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}/members 表1 路径参数 参数
不连续的现象。 Kafka生产者客户端3.0及之后的版本会默认开启幂等，如果不需要使用该功能，请将“enable.idempotence”设置为“false”。 父主题： 消息问题
e动作为止。 问题规避 建议用户根据业务区分不同消费组使用，降低单消费者阻塞导致的影响访问。 max.poll.interval.ms用于设置消费组请求消费消息的最大时间间隔，如果消费者在超时前没有发起下一次消费请求，服务端会触发rebalance。调大max.poll.interval
修改Kafka的接入方式 功能介绍 修改Kafka的内网或者公网接入方式。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/{engine}/instances/{instance_id}/plain-ssl-switch 表1 路径参数 参数
创建转储任务 功能介绍 创建转储任务。 当前页面API为历史版本API，未来可能停止维护。请使用开启Smart Connect（按需实例）。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/connectors/{connector_id}/sink-tasks
对端Kafka开启SASL_SSL时设置的用户名，或者创建SASL_SSL用户时设置的用户名。（仅源端类型为Kafka且对端Kafka认证方式为“SASL_SSL”时需要填写） password 否 String 对端Kafka开启SASL_SSL时设置的密码，或者创建SASL_SSL用户时设置的密码。（
String Kafka实例的基准带宽。 available_zones Array 实例资源未售罄的可用区。 ecs_flavor_id String 该产品规格对应的虚拟机规格。 arch_type String 实例规格架构类型。当前仅支持X86。 表6 io参数说明 参数 类型
按需计费Kafka实例生命周期 欠费预警 系统会在每个计费周期后的一段时间对按需计费资源进行扣费。当您的账户被扣为负值时，我们将通过邮件、短信和站内信的方式通知到华为云账号的创建者。 欠费后影响 账号欠费，资源进入宽限期 当您的账号因按需Kafka实例自动扣费导致欠费后，账号将变成欠费状态。欠费后，按需资源
查询Kafka集群元数据信息 功能介绍 查询Kafka集群元数据信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/cluster 表1 路径参数 参数 是否必选 参数类型
查询所有消费组 功能介绍 查询所有消费组。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。
主题管理，包括Topic管理接口对应的授权项，如创建Topic、查询Topic、修改Topic等接口。 用户管理，包括用户管理接口对应的授权项，如创建用户、查询用户列表、设置用户权限等接口。 消息查询，包括消息查询接口对应的授权项，如查询消息接口。 后台任务管理，包括实例的后台任务管理接口对应的授权项，如查询实
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
