检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka实例是否支持查看单个Topic占用磁盘空间？ Topic是否支持ACL权限配置？ 消息被消费后，没有删除，导致Kafka存储空间占满？ 如何扩总分区？ 修改自动创建Topic的配置，会触发重启吗？ 消费者消费Topic失败，提示没有权限？
是否支持跨Region访问？ Kafka实例是否支持跨VPC访问？ Kafka实例是否支持不同的子网？ Kafka是否支持Kerberos认证，如何开启认证？ Kafka实例是否支持无密码访问？ 开启公网访问后，在哪查看公网IP地址？ Kafka支持服务端认证客户端吗？ 连接开启SASL_SSL的Kafka实例时，ssl
在Kafka Manager上支持修改Topic的哪些属性？ Kafka Manager和云监控显示的信息不一致 Kafka Manager如何修改Topic的分区Leader？ 实例版本在控制台和Kafka Manager上显示不一致？ 为什么实例中存在默认名为__trace和_
图1 我的配额 您可以在“服务配额”页面，查看各项资源的总配额及使用情况。 如果当前配额不能满足业务要求，请参考后续操作，申请扩大配额。 如何申请扩大配额？ 登录管理控制台。 在页面右上角，选择“资源 > 我的配额”。 系统进入“服务配额”页面。 单击“申请扩大配额”。 在“新建
网络正常，如下： 网络异常/不通，如下： 解决方案： 检查是否同一个VPC。如果不是，请参考跨VPC访问。 检查安全组规则是否配置正确。请参考如何选择和配置安全组。 检查Consumer和Producer的配置 查看日志，检查Consumer和Producer初始化时打印的参数是否符
如果在配置参数中设置“auto.create.groups.enable”为“true”，系统会自动创建消费组，无需手动创建。 本章节介绍如何在控制台创建消费组，此操作不会导致Kafka实例重启。 约束与限制 2023年4月25日及以后创建的实例，支持在控制台创建消费组。 如果“auto
书有效期足够长（超过15年），客户端不需要关注证书过期风险。 查看SSL证书有效期的方法如下： 解压从Kafka实例控制台下载的压缩包，获取压缩包中的“phy_ca.crt”。 双击“phy_ca.crt”，弹出“证书”对话框。 在“常规”页签中，获取证书有效期。 图1 证书有效期
消费组订阅的Topic分区数发生变化。 重平衡日志记录Rebalance的详情，包括Rebalance时间、原因和触发Rebalance的客户端等。本章节介绍如何在控制台查看重平衡日志。 重平衡日志存储在云日志服务（Log Tank Service，简称LTS）中，由LTS提供查询功能。 约束与限制
升级过程中会逐个节点升级，单个节点的升级包括两部分：升级软件包和数据同步。升级软件包耗时在5分钟左右，数据同步耗时取决于升级软件包过程中其他节点Leader副本的生产数据量，数据量越大，所需时间越久。升级总耗时=每个节点升级软件包耗时+数据同步耗时。 升级过程中会逐个节点重启监控进程，
Kafka实例的网络带宽主要由以下两个部分组成： 实例Broker对应的网络带宽 实例Broker的磁盘所对应的带宽值（不同类型的磁盘对应的带宽值不同，具体参考：如何选择磁盘类型） 注意事项： Kafka默认情况下测试均为尾读场景（即仅消费最新生产的数据），而不是冷读场景（即从头开始消费历史数据的场景）。
重启生产客户端，将生产业务迁移到新Kafka实例中。 生产业务迁移后，观察连接新Kafka实例的消费业务是否正常。 迁移结束。 常见问题：如何将持久化数据也一起迁移 如果需要将原Kafka的已消费数据也迁移到Kafka实例，可以使用Smart Connect工具，模拟成原Kafk
可以在SDK中心查询版本信息。 表1提供了分布式消息服务Kafka版支持的SDK列表，您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。 表1 SDK列表 编程语言 Github地址 参考文档 Java huaweicloud-sdk-java-v3 Java
当您选择开启，表示生产或消费一个未创建的Topic时，会自动创建一个包含3个分区和3个副本的Topic。 storage_spec_code String 是 存储IO规格。如何选择磁盘类型请参考磁盘类型及性能介绍。 取值范围： 参数specification为100MB时，取值dms.physical.storage
安装后注意配置JAVA的环境变量。 IntelliJ IDEA 获取并安装IntelliJ IDEA，可至IntelliJ IDEA官方网站下载。 操作步骤 下载Demo包。 下载后解压，有如下文件： 表1 Kafka Demo文件清单 文件名 路径 说明 DmsConsumer.java .\src\main
务端才认为此消费组客户端已下线。 当前页面API为历史版本API，未来可能停止维护。请使用重置消费组消费进度到指定位置。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/management/g
创建实例时会进行磁盘格式化，磁盘格式化会导致实际可用磁盘为总磁盘的93%~95%。 磁盘类型支持高I/O、超高I/O、极速型SSD和通用型SSD，更多磁盘信息请参考如何选择磁盘类型。 图1 综合推荐 规格测算：系统根据您选择的版本号和输入的参数（生产流量峰值、消费流量、单个Topic副本数、总分区数和老化
5 linux/amd64 如果未安装Go，参考如下步骤安装。 #下载Go安装包。 wget https://go.dev/dl/go1.16.5.linux-amd64.tar.gz #解压安装包到“/usr/local”目录，“/usr/local”目录可以根据实际情况修改。
获取证书的方法如下：在Kafka控制台单击Kafka实例名称，进入实例详情页面，在“连接信息 > SSL证书”所在行，单击“下载”。解压压缩包，获取压缩包中的客户端证书文件：client.jks。 “/root”为证书存放路径，请根据实际情况修改。 进入Kafka客户端文件的“/config”目录下。
可以选择让一部分消费者处于wait状态。 代码示例 以下仅贴出与消费者线程唤醒与睡眠相关代码，如需运行整个demo，请先下载完整的代码示例包，同时参考开发指南进行部署和运行。 消费消息代码示例： package com.huawei.dms.kafka; import java
not found the new setup version tar to upgrade instance. 实例升级未找到新版本安装包。 请重新选择升级的版本号 400 DMS.00400052 only the instance at running status can
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
