检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka消息堆积了怎么办？ 问题现象：实例的监控指标“堆积消息数”产生了告警。 处理方法1： 登录Kafka实例控制台，单击产生告警的实例名称，进入实例详情页。 在左侧导航栏，单击“监控与告警 > 监控详情”，进入监控页面。 在“消费组”页签中，查看“消息堆积数（消费组可消费消息数）”，找出消息堆积的消费组。
信息栏左上侧的“续费”，弹出“续费”对话框，单击“是”，跳转到“续费”页面。 在待续费的Kafka实例所在行，单击“更多 > 续费”，跳转到“续费”页面。 单击Kafka实例名称，进入实例详情页面。单击右上角的“续费”，跳转到“续费”页面。 选择Kafka实例的续费时长，判断是否
置弹性IP地址。 单击“创建弹性IP”，跳转到“购买弹性公网IP”页面，购买弹性IP地址，具体操作请参考申请弹性公网IP。 购买完成后，返回开启公网页面。 单击“弹性IP地址”后的，然后在下拉框中选择和代理数量相同的弹性IP地址，单击，跳转到“后台任务管理”页面。 当任务状态显示为“成功”时，表示成功开启公网访问。
为什么云监控页面无法展示Kafka监控数据？ 为什么限制Topic的总分区数？ Kafka实例的Topic数量是否有限制 Kafka消息堆积了怎么办？ Kafka实例的ZK地址是什么？能否直接连接？ 为什么Console页面上，消息查询查不到消息？ 为什么实例可用区不能选择2个？ 更多
为什么Kafka实例常常发生Rebalance（重平衡），导致消息拉取失败？ 为什么Console页面上，消息查询查不到消息？ Kafka消息堆积了怎么办？ 消息超过老化时间，消息仍存在的原因 Kafka实例是否支持延迟消息？ 如何查看堆积消息数？ 为什么消息创建时间显示1970？ 如何修改message
将业务中属于非核心或不重要的流程部分，使用消息异步通知的方式发给目标系统，这样主业务流程无需同步等待其他系统的处理结果，从而达到系统快速响应的目的。 如网站的用户注册场景，在用户注册成功后，还需要发送注册邮件与注册短信，这两个流程使用Kafka消息服务通知邮件发送系统与短信发送系统，从而提升注册流程的响应速度。
Kafka实例是否支持查看单个Topic占用磁盘空间？ 支持。通过以下任意一种方法，查看单个Topic占用磁盘空间大小。 在Kafka实例名称所在行，单击“查看监控数据”，跳转到云监控页面。在“主题”页签中，“主题”选择待查看磁盘空间大小的Topic名称，“监控类型”选择“基本监控”，查看“队列数据容量”，该指标表示该队列当前的消息数据大小。
分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 通过以下任意一种方法，查看监控数据。 在Kafka实例名称后，单击“查看监控数据”。跳转到云监控页面，查看实例、节点、主题、消费组和Smart Connect的监控数据，数据更新周期为1分钟。 单击Kafka实例名称，进入实例详情页。在左侧导航栏单击“监控与告警
页面支持从以下三个方面对代理中的Topic磁盘使用量进行查询：使用量排名前xx个、使用量达到xx GB和使用占比达xx%。 在页面右上角，单击“查看监控数据”，跳转到云监控服务的监控指标页面。在监控指标页面，您可以查看Kafka实例的各项监控指标。 图1 查看磁盘的使用量 父主题： 管理实例
“转包周期”对话框，单击“是”，跳转到“按需转包年/包月”页面。 在待转包周期的Kafka实例所在行，单击“更多 > 转包周期”，跳转到“按需转包年/包月”页面。 单击Kafka实例名称，进入实例详情页面。单击右上角的“更多 > 转包周期”，跳转到“按需转包年/包月”页面。 选择
单击“确认”，跳转到“后台任务管理”页面。当任务状态显示为“成功”时，表示成功开启明文接入。 公网访问明文接入 确认公网访问已开启，如果未开启，请开启公网访问，具体步骤参考配置Kafka实例的公网访问。 在“公网访问 > 明文接入”后，单击，弹出确认对话框。 单击“确认”，跳转到“后台
页面右上角直接提示修改结果。 内网访问 修改方法请参考配置Kafka实例的明文/密文接入。 系统跳转到“后台任务管理”页面，并显示当前任务的操作进度和结果。 公网访问 修改方法请参考配置Kafka实例的公网访问。 系统跳转到“后台任务管理”页面，并显示当前任务的操作进度和结果。 容量阈值策略 单击待
未开启密文接入的实例，在“创建流控”对话框中，不显示“用户名”。 “用户名”和“客户端ID”不可同时为空。 “生产上限速率”和“消费上限速率”不可同时为空。 单击“确定”，跳转到“后台任务管理”页面，当流控任务的“状态”为“成功”时，表示流控创建成功。 进入“流控管理 > 流控列表”页面，在“User/Clien
租户不需要单独采购硬件资源，直接使用就绪的服务，无需额外成本。 需要购买硬件资源，自行搭建整个消息服务，使用和维护成本高。 实践验证 成熟度高 经受电商网站大规模访问考验，并且已经在华为云许多产品中使用，广泛部署运行在分布于世界各地的电信级客户云业务系统里。满足严苛的电信级故障模式库标准。紧随
数据量大的Topic进行分区平衡的时间会比较长，建议根据Topic的消费情况，适当调小Topic老化时间，使得Topic的部分历史数据被及时清理，加快迁移速度。Topic的数据量可以通过监控页面的“队列数据容量”查看，具体步骤请参考查看Kafka监控数据。 分区平衡前的准备工作
Manager创建的Topic，在Topic详情页面不显示创建时间。 订阅关系：包含消费组名称、消费组状态、Coordinator(ID)和堆积数。 单击消费组名称，跳转到对应消费组的详情页面。 如果一个实例中消费组数量超过10000，则不支持查询Topic的订阅关系。 图1 订阅关系 分区信息：包含分区编
安装后注意配置JAVA的环境变量。 IntelliJ IDEA 获取并安装IntelliJ IDEA，可至IntelliJ IDEA官方网站下载。 操作步骤 下载Demo包。 下载后解压，有如下文件： 表1 Kafka Demo文件清单 文件名 路径 说明 DmsConsumer
选择已经创建好的或共享的虚拟私有云。 虚拟私有云可以为您的Kafka实例构建隔离的、能自主配置和管理的虚拟网络环境。您可以单击右侧的“管理虚拟私有云”，跳转到网络控制台的“虚拟私有云”页面，查看或创建虚拟私有云。 虚拟私有云在Kafka实例创建完成后，不支持修改。 子网 选择已经创建好的或共享的子网。
存储Key 是否转储Key，开启表示转储Key，关闭表示不转储Key。 消息进行转储时，不支持以Key作为文件名。 单击“立即创建”，跳转到Smart Connect任务列表页面，页面右上角显示“创建xxx任务成功”。 父主题： 使用Smart Connect迁移数据
数据量大的Topic进行分区平衡的时间会比较长，建议根据Topic的消费情况，适当调小Topic老化时间，使得Topic的部分历史数据被及时清理，加快迁移速度。Topic的数据量可以通过监控页面的“队列数据容量”查看，具体步骤请参考查看Kafka监控数据。 分区平衡前的准备工作
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
