检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
pic生产或消费消息时，系统会自动创建此Topic。 其他建议 连接数限制：3000 消息大小：不能超过10MB 使用SASL_SSL协议访问Kafka：确保DNS具有反向解析能力，或者在hosts文件配置Kafka所有节点IP和主机名映射，避免Kafka client做反向解析，阻塞连接建立。
支持变更为包年/包月计费模式。 变更规格 支持变更实例规格。 支持变更实例规格。 回收站中实例是否计费 开启回收站策略的包年/包月实例，退订后会存入回收站中，此时不收取实例费用，但是会按需收取存储空间费用。 从回收站中恢复的包年/包月实例，计费模式会变为按需计费。 开启回收站策略的按需实例，删除后会存入回收站
为什么实例可用区不能选择2个？ 更多 实例问题 Kafka实例的ZK地址是什么 Kafka实例的SASL_SSL开关如何修改？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？ 更多 Topic与分区 为什么限制Topic的总分区数？ 为什么不支持减少分区数？ 是否支持自动生成Topic功能？
计费模式下的费用计算过程，请参见计费样例。 续费 包年/包月Kafka实例在到期后会影响Kafka实例的正常运行。如果您想继续使用Kafka实例，需要在规定的时间内为Kafka实例进行续费，否则Kafka实例、磁盘存储空间等资源将会自动释放，数据也可能会丢失。续费包括手动续费和自
权限管理 创建用户并授权使用DMS for Kafka
管理消息 查看Kafka消息 修改Kafka消息老化时间 删除Kafka消息 诊断Kafka消息积压
个消费组消费阻塞，一直到该消费者响应rebalance动作为止。 问题规避 建议用户根据业务区分不同消费组使用，降低单消费者阻塞导致的影响访问。 max.poll.interval.ms用于设置消费组请求消费消息的最大时间间隔，如果消费者在超时前没有发起下一次消费请求，服务端会触发rebalance。调大max
管理消费组 创建Kafka消费组 查看Kafka消费组信息 查看Kafka消费者信息 查看和重置Kafka消费进度 查看Kafka重平衡日志 修改Kafka消费组信息 导出Kafka消费组列表 删除Kafka消费组
Java开发环境搭建 基于收集连接信息的介绍，假设您已经获取了实例连接相关的信息，以及配置好客户端的网络环境。本章节以生产与发送消息的Demo为例，介绍Kafka客户端的环境配置。 开发环境 Maven Apache Maven 3.0.3及以上版本，可至Maven官方下载页面下载。
以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 ssl_enable 否 Boolean 是否开启SASL加密访问。 true：开启SASL加密访问。 false：关闭SASL加密访问。 kafka_security_protocol
支持的授权项 策略包含系统策略和自定义策略，如果系统策略不满足授权要求，管理员可以创建自定义策略，并通过给用户组授予自定义策略来进行精细的访问控制。策略支持的操作与API相对应，授权项列表说明如下： 权限：允许或拒绝某项操作。 对应API接口：自定义策略实际调用的API接口。 授
使用Kafka数据复制时，两个Kafka实例间只能通过内网连接。如果两个Kafka实例处于不同的VPC中，请先打通网络，方法可以参考使用VPCEP实现跨VPC访问Kafka或者对等连接。 Smart Connect任务创建成功后，不支持修改任务参数。 2022年7月1日前已开启Smart Conne
根据企业的业务组织，在您的华为账号中，给企业中不同职能部门的员工创建IAM用户，让员工拥有唯一安全凭证，并使用DMS for Kafka资源。 根据企业用户的职能，设置不同的访问权限，以达到用户之间的权限隔离。 将DMS for Kafka资源委托给更专业、高效的其他华为账号或者云服务，这些账号或者云服务可以根据权限进行代运维。
储空间账单。 在Kafka实例列表页面如下图所示位置单击鼠标左键，复制实例的资源ID。 图2 获取资源ID（实例） 单击实例名称，进入实例详情页，查看存储空间的资源ID。 图3 获取资源ID（存储空间） 进入“费用中心 > 流水和明细账单”页面。 选择“明细账单”，在筛选条件中选
息服务Kafka版的其他监控指标设置告警通知。 前提条件 已购买Kafka实例、创建Topic，并且已成功消费消息。 实施步骤 登录分布式消息服务Kafka版控制台，单击待创建告警通知的实例名称，进入实例详情页。 在左侧导航栏，选择“监控与告警 > 监控详情”，进入监控详情页面。
统计Broker节点每秒网络访问流入流量。 单位：Byte/s 2020年6月及以后购买的实例，支持此监控项。 0~1000000000 Kafka实例节点 1分钟 broker_total_bytes_out_rate 网络出流量 统计Broker节点每秒网络访问流出流量。 单位：Byte/s
例如IAM服务在“华北-北京四”区域的Endpoint为“iam.cn-north-4.myhuaweicloud.com”。 resource-path 资源路径，即API访问路径。从具体API的URI模块获取，例如“管理员创建IAM用户”API的resource-path为“/v3.0/OS-USER/users”。
location=E:\\temp\\client.jks #ssl truststore.password为服务器证书密码，配置此密码是为了访问Java生成的jks文件。 ssl.truststore.password=dms@kafka #ssl.endpoint.identification
根据对数据与服务的不同可靠性要求，您可以选择在单可用区内（单机房）部署Kafka实例，或跨可用区（同城灾备）部署，也可以通过数据同步工具（MirrorMaker）进行跨实例的数据同步。 在单可用区或多可用区中部署实例 使用MirrorMaker跨实例数据同步 副本冗余 副本通过数据同步的方式保持数据一致，
rabbitmqInstance表示RabbitMQ实例配额。 kafkaInstance表示Kafka实例配额。 rocketmqInstance表示RocketMQ实例配额。 tags表示标签的配额。 quota Integer 租户最大可以创建的实例个数，或者每个实例最大可以创建的标签个数。 used
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
