检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka体验版使用说明 Kafka体验版实例规格为EXP，为单代理实例，不支持Kafka Manager、Smart Connect和多AZ等功能。 Kafka体验版实例只适用体验和业务测试场景，无法保证性能和可靠性。如果需要在生产环境使用Kafka实例，建议购买按需或包年包月的Kafka实例。
子网在Kafka实例创建完成后，不支持修改。 子网开启IPv6后，Kafka实例支持IPv6功能。 IPv6 子网开启IPv6后，页面才显示此参数。开启IPv6后，客户端可以使用IPv6地址连接实例。 开启IPv6的实例不支持动态开启和关闭SASL_SSL功能。 实例创建成功后，不支持修改IPv6开关。
单击Kafka实例的名称，进入实例详情页面。 在左侧导航栏单击“重平衡日志”，进入“重平衡日志”页面。 单击“开启日志”，页面右上角显示“重平衡日志开启成功”时，表示开启重平衡日志成功。 开启重平衡日志后，会在LTS控制台创建对应的日志组和日志流。 查看重平衡日志 登录管理控制台。 在管理控制台左上角单击，选择区域。
分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积，从而会造成消息消费延迟。 分布式消息服务Kafka版在控制台提供了消息积压诊断功能，如果消息存在堆积，诊断后会生成诊断记录，诊断记录显示消息堆积可能的原因、受影响的分区或者broker，以及解决消息堆积的建议。 前提条件
分布式消息服务Kafka版 介绍消息积压诊断功能 03:18 消息积压诊断 操作指导 分布式消息服务Kafka版 介绍怎样购买Kafka实例 07:58 购买Kafka实例 分布式消息服务Kafka版 介绍怎样连接未开启SASL的Kafka实例 04:57 连接未开启SASL的Kafka实例 分布式消息服务Kafka版
查询可用区信息 当前页面API为历史版本API，未来可能停止维护。请使用查询可用区信息。 功能介绍 在创建实例时，需要配置实例所在的可用区ID，可通过该接口查询可用区的ID。 URI GET /v1.0/availableZones 请求消息 请求参数 无。 请求示例 GET h
在左侧导航栏选择“Topic管理”，进入Topic列表页面。 执行以下步骤，弹出“消息删除”对话框。 如果实例未开启密文接入功能，在待删除消息的Topic所在行，单击“消息删除”。 如果实例已开启密文接入功能，在待删除消息的Topic所在行，单击“更多 > 消息删除”。 设置消息删除参数，如表1所示。
实例管理 重置密码 重置Manager密码 重启Manager 开启或关闭实例自动创建topic功能 修改实例跨VPC访问的内网IP 查询Kafka集群元数据信息 查询消费组信息 查询Kafka实例的协调器信息 修改Kafka实例Topic分区的副本 查询topic的磁盘存储情况
keeper数据的存储，因而实际可用存储会小于购买存储。 其中，副本数在创建Topic时可以选择，默认为3副本存储。如果开启了Kafka自动创建Topic功能，自动创建的Topic默认为3副本，副本数可以通过“配置参数”页签中的“default.replication.factor”修改。
修改Kafka实例创建Topic和新增Kafka实例指定Topic分区的分区数最大值。 2021-05-11 本次变更如下： 修改开启或关闭实例自动创建topic功能的返回状态码和返回描述。 2021-04-16 新增以下接口： 查询用户列表 创建用户 批量删除用户 重置用户密码 查询用户权限
制。在Kafka实例控制台的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了，根据实际情况选择其中任意一种配置连接。很久前创建的Kafka实例在详情页如果未显示“开启的SASL认证机制”，默认使用PLAIN机制。 security_protocol：Kafk
Topic分区数，设置消费的并发数。 retention_time Integer 消息老化时间。 sync_replication Boolean 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效。 默认关闭。 sync_message_flush Boolean 是
PREPARING_REBALANCE：准备开启Rebalance。 COMPLETING_REBALANCE：所有成员加入消费组。 STABLE：消费组内成员可以正常消费。 弹出“删除消费组”对话框，单击“确定”，完成消费组的删除。 使用命令行工具删除消费组 以下操作命令以Linux系统为例进行说明： 未开启密文接
比如LZ4；对于需要更高压缩比的系统，可以选择压缩率高的算法，比如GZIP。 可以在生产者端配置“compression.type”参数来启用指定类型的压缩算法。 Properties props = new Properties(); props.put("bootstrap.servers"
也为空，系统分配一个默认结束时间06:00:00。 enable_publicip Boolean 否 实例是否开启公网访问功能。 true：开启 false：不开启 public_bandwidth String 否 表示公网带宽，单位是Mbit/s。 取值范围： Kafka实
mechanism：SASL认证机制。在Kafka实例控制台的基本信息页面中获取。如果SCRAM-SHA-512和PLAIN都开启了，根据实际情况选择其中任意一种配置连接。很久前创建的Kafka实例在详情页如果未显示“开启的SASL认证机制”，默认使用PLAIN机制。 非SASL认证方式 package main
Integer 否 副本数，配置数据的可靠性 默认值为3，取值范围为1~3。 sync_replication Boolean 否 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效。 默认关闭。 retention_time Integer 否 消息老化时间。默认值为72。
throughput：每秒发送的消息数。 测试结果 测试场景一（实例是否开启SASL）：相同的Topic（30分区、3副本、异步复制、异步落盘），实例分为开启SASL和未开启SASL，测试结果如下： 表3 测试结果 实例规格 磁盘类型 代理数量 TPS（开启SASL） TPS（未开启SASL） kafka.2u4g.cluster
修改自动创建Topic的配置，会触发重启吗？ 开启或者关闭“Kafka自动创建Topic”，会导致Kafka重启。 父主题： Topic和分区问题
查询可用区信息 功能介绍 在创建实例时，需要配置实例所在的可用区ID，可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码： 200 表1 响应Body参数 参数 参数类型 描述 region_id
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
