检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
添加标签 单击“创建/删除标签”，弹出“创建/删除标签”对话框。 在“标签键”和“标签值”中，输入标签的键/值，单击“添加”。 如果您已经预定义了标签，在“标签键”和“标签值”中选择已经定义的标签键/值，单击“添加”。 单击“确定”，成功为实例添加标签。 删除标签 通过以下任意一种方法，删除标签。
自动创建“mm2-offset-syncs.对端Kafka实例别名.internal”的Topic。如果Smart Connect任务开启了“同步消费进度”功能，且“同步方式”为“拉取”/“双向”时，当前Kafka实例还会自动创建“对端Kafka实例别名.checkpoints.
6581，代入公式可得升配费用=3780*0.6581-1890*0.6581=1243.81（元） 更多信息请参见变更资源规格费用说明。 到期后影响 图3描述了包年/包月Kafka实例各个阶段的状态。购买后，在计费周期内Kafka实例正常运行，此阶段为有效期；Kafka实例到期而未续费时，将陆续进入宽限期和保留期。
费。 统一包年/包月资源的到期日 如果您持有多台到期日不同的Kafka实例，可以将到期日统一设置到一个日期，便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源，同时续费一个月，并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。
确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 通常不建议对每条消息都进行commit，如果对每条消息都进行了commit，会导致OFFSET_COMMIT请求过多，进而导致CPU使用率过高。例如：如果一个消费请求拉取1000条消息，每条都commi
是否开启公网访问开关。 公网连接地址 开启公网访问后，连接实例的地址。 仅当开启了公网访问才显示该参数。 Manager公网访问地址 开启公网访问后，连接Kafka Manager的地址。 仅当开启了公网访问才显示该参数。 2023年5月17日及以后创建的实例不提供此地址。 VPC内网明文访问
高可靠：all或者-1 高吞吐：1 收到Server端确认信号个数，表示producer需要收到多少个这样的确认信号，算消息发送成功。acks参数代表了数据备份的可用性。常用选项： acks=0：表示producer不需要等待任何确认收到的信息，副本将立即加到socket buffer并认为
查询Kafka集群元数据信息 当前页面API为历史版本API，未来可能停止维护。请使用查询Kafka集群元数据信息。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/cluster 参数说明如下表所示。 表1 参数说明
控制台提示为准。实例重启大约需要75~80s。后续再次修改接入方式时，实例不会再重启。 单机实例只支持开启/关闭公网访问的明文接入。 开启了IPv6功能后，不支持修改实例的接入方式。 前提条件 只有处于“运行中”状态的Kafka实例才可以修改接入方式。 开启明文接入 登录管理控制台。
分区平衡任务无法结束。 分区平衡任务启动后，无法修改Topic的分区数。 分区平衡任务启动后，无法手动停止任务，需要等到任务完成。 已设置了一个定时分区平衡任务，在此任务未执行前，无法对本实例内的任何Topic执行其他分区平衡任务。 分区平衡后Topic的metadata会改变，
分区平衡任务无法结束。 分区平衡任务启动后，无法修改Topic的分区数。 分区平衡任务启动后，无法手动停止任务，需要等到任务完成。 已设置了一个定时分区平衡任务，在此任务未执行前，无法对本实例内的任何Topic执行其他分区平衡任务。 分区平衡后Topic的metadata会改变，
点个数的倍数。 publicip_id String 否 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 ssl_enable Boolean 否 是否打开SSL加密访问。
public_bandwidth Integer 公网带宽。 public_connect_address String 实例公网连接IP地址。当实例开启了公网访问，实例才包含该参数。 kafka_manager_user String 登录Kafka Manager的用户名。 enable_log_collection
这样造成了一定的资源浪费。 图1 Kafka消费者多线程消费模式 解决方案 在开了多个线程同时访问的情况下，如果Topic里已经没有消息了，其实不需要所有的线程都在poll，只需要有一个线程poll各分区的消息就足够了，当在polling的线程发现Topic中有消息，可以唤醒其
Integer 总共消息存储空间，单位：GB。 public_connect_address String 实例公网连接IP地址。当实例开启了公网访问，实例才包含该参数。 storage_resource_id String 存储资源ID。 storage_spec_code String
查询Kafka集群元数据信息 功能介绍 查询Kafka集群元数据信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/cluster 表1 路径参数 参数 是否必选 参数类型
public_connect_address String 实例公网连接IP地址。当实例开启了公网访问，实例才包含该参数。 public_connect_domain_name String 实例公网连接域名。当实例开启了公网访问，实例才包含该参数。 storage_resource_id String
public_connect_address String 实例公网连接IP地址。当实例开启了公网访问，实例才包含该参数。 public_connect_domain_name String 实例公网连接域名。当实例开启了公网访问，实例才包含该参数。 storage_resource_id String
false：不开启 publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 ssl_enable 否 Boolean 是否打开SSL加密访问。
升级版本与当前版本相同 请重新选择升级的版本号 400 DMS.00400055 Resource sold out. 资源不足，包括ecs，volume等 请稍后再试 400 DMS.00400060 This instance name already exists. 实例名称已经存在。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
