检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用MirrorMaker跨集群同步数据 使用MirrorMaker可以实现将源集群中的数据镜像复制到目标集群中。 配置消息堆积数监控 介绍如何设置消息组的消息堆积数超过阈值时，消息通知服务及时发送告警短信/邮件通知用户。
Kafka实例是否支持查看单个Topic占用磁盘空间？ Topic是否支持ACL权限配置？ 消息被消费后，没有删除，导致Kafka存储空间占满？ 如何扩总分区？ 修改自动创建Topic的配置，会触发重启吗？ 消费者消费Topic失败，提示没有权限？
页面。 单击Kafka实例名称，进入实例详情页。 在左侧导航栏选择“监控与告警 > 告警”，进入“一键告警”页面。 告警规则的默认状态为“关闭”，单击“前往CES配置一键告警”，跳转到云监控服务控制台的“一键告警”页面。 图2 一键告警 在顶部搜索框中单击鼠标左键，选择“资源类型
在Kafka Manager上支持修改Topic的哪些属性？ Kafka Manager和云监控显示的信息不一致 Kafka Manager如何修改Topic的分区Leader？ 实例版本在控制台和Kafka Manager上显示不一致？ 为什么实例中存在默认名为__trace和_
项”、“到期不续费项”页签查询全部待续费资源，对资源进行手动续费的操作。 所有需手动续费的资源都可归置到“手动续费项”页签，具体操作请参见如何恢复为手动续费。 手动续费资源。 单个续费：在资源页面找到需要续费的资源，单击操作列的“续费”。 图2 单个续费 批量续费：在资源页面勾选
图1 我的配额 您可以在“服务配额”页面，查看各项资源的总配额及使用情况。 如果当前配额不能满足业务要求，请参考后续操作，申请扩大配额。 如何申请扩大配额？ 登录管理控制台。 在页面右上角，选择“资源 > 我的配额”。 系统进入“服务配额”页面。 单击“申请扩大配额”。 在“新建
务端才认为此消费组客户端已下线。 当前页面API为历史版本API，未来可能停止维护。请使用重置消费组消费进度到指定位置。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/management/g
从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET https://{Endpoint}/v3/projects”，其中{Endpoint}为IAM的终端节点，可以从地区和终端节点获取。接口的认证鉴权请参见认证鉴权。
allFailure String 否 参数值为kafka，表示删除租户所有创建失败的Kafka实例。 请求示例 批量重启实例 POST https://{dms_endpoint}/v1.0/{project_id}/instances/action { "action"
Kafka实例的网络带宽主要由以下两个部分组成： 实例Broker对应的网络带宽 实例Broker的磁盘所对应的带宽值（不同类型的磁盘对应的带宽值不同，具体参考：如何选择磁盘类型） 注意事项： Kafka默认情况下测试均为尾读场景（即仅消费最新生产的数据），而不是冷读场景（即从头开始消费历史数据的场景）。
与RabbitMQ、RocketMQ的差异 表1 功能差异 功能项 RocketMQ Kafka RabbitMQ 优先级队列 不支持 不支持 3.8.35版本：支持。建议优先级大小设置在0-10之间。 AMQP-0-9-1版本：支持。优先级大小设置在1-9之间。 延迟队列 支持
如果在配置参数中设置“auto.create.groups.enable”为“true”，系统会自动创建消费组，无需手动创建。 本章节介绍如何在控制台创建消费组，此操作不会导致Kafka实例重启。 约束与限制 2023年4月25日及以后创建的实例，支持在控制台创建消费组。 如果“auto
DMS for Kafka安全使用建议 安全性是华为云与您的共同责任。华为云负责云服务自身的安全，提供安全的云；作为租户，您需要合理使用云服务提供的安全能力对数据进行保护，安全地使用云。详情请参见责任共担。 本文提供了使用DMS for Kafka过程中的安全最佳实践，旨在为提高
Integer 期望调整分区后的数量，必须大于当前分区数量，小于等于 100。 响应参数 无 请求示例 增加Topic分区数。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/top
String 是 项目ID。 instance_id String 是 实例ID。 请求消息 请求参数 无。 请求示例 DELETE https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id} 响应消息 响应参数
time_base: 自动删除 enterprise_project_id String 否 企业项目。 请求示例 示例1 ： PUT https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id} { "name":
参数说明见表2。 表2 参数说明 参数 类型 是否必选 说明 topics Array 是 待删除的topic列表 请求示例 POST https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id}/topics/delete
查询维护时间窗开始时间和结束时间。 URI GET /v1.0/instances/maintain-windows 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/instances/maintain-windows 响应消息 响应参数 参数说明见表表1、表2
创建用户并授权使用DMS for Kafka 如果您需要对您所拥有的DMS for Kafka服务进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以： 根据企业的业务组织，在您的华为账号中
可通过该接口查询可用区的ID。 URI GET /v1.0/availableZones 请求消息 请求参数 无。 请求示例 GET https://{dms_endpoint}/v1.0/availableZones 响应消息 响应参数 参数说明见表1、表2。 表1 参数说明 参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
