检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
获取Kafka开源客户端 Kafka实例支持多种语言的客户端，如果您想要使用其他语言连接Kafka实例，可以从Kafka官网获取客户端。 Kafka官网支持的客户端语言包括：C/C++、Python、Go、PHP、Node.js等等。 Kafka实例完全兼容开源客户端，按照Kafka
下载的证书JKS和CRT有什么区别？ 使用Java语言连接实例时，需要用JKS格式的证书。使用Python语言连接实例时，需要用CRT格式的证书。 父主题： 连接问题
下线区域：所有区域 下线影响 该版本停售后，新用户将无法进行购买，已购买该版本的用户不受影响，可继续使用扩容等功能。 如您有任何问题，可随时通过工单或者服务热线（4000-955-988或950808）与我们联系。 常见问题 已经购买Kafka 2.3.0的用户能否继续使用？Kafka 2.3
者没有消息时的资源浪费。 Logstash对接Kafka生产消费消息 Kafka实例可以作为Logstash输入源，也可以作为Logstash输出源。本章节介绍Logstash如何对接Kafka实例生产消费消息。 使用MirrorMaker跨集群同步数据 使用MirrorMake
前提条件 请确认包年/包月Kafka实例还未到期。 在购买Kafka实例页面开通自动续费 您可以在购买Kafka实例页面开通自动续费，如图1所示。更多购买Kafka实例的信息，请参见购买实例。 图1 自动续费配置 在购买Kafka实例时开通的自动续费遵循以下规则： 按月购买：自动续费周期为1个月。
变更计费模式概述 在购买Kafka实例后，如果发现当前计费模式无法满足业务需求，您可以变更计费模式。支持变更计费模式的Kafka实例计费项如表1所示。 表1 支持变更计费模式的Kafka实例计费项 计费项 变更说明 相关文档 实例规格 变更Kafka实例的计费模式会同时变更实例规格和存储空间的计费模式。
您可以根据业务需要创建相应计算能力和存储空间的Kafka实例。 API调用方法请参考如何调用API。 前提条件 已获取IAM的Endpoint，具体请参见地区和终端节点。 已获取Kafka的Endpoint，具体请参见地区和终端节点。 创建Kafka实例 如下示例是创建Kafka实例的请求消息： { "name":
log file on the disk”错误。 根因描述 节点磁盘使用率超高导致生产消息失败。 问题解决措施 扩容实例的磁盘空间，具体操作请参考变更Kafka实例规格。
instance name already exists. 实例名称已经存在。 请检查实例名称 400 DMS.00400061 Invalid instance ID format. 实例ID的格式无效。 请检查实例ID 400 DMS.00400062 Invalid request
查询产品规格列表 功能介绍 在创建Kafka实例时，需要配置订购的产品ID（即product_id），可通过该接口查询产品规格。 例如，要订购按需计费、基准带宽为100MB的Kafka实例，可从接口响应消息中，查找Hourly的消息体，然后找到bandwidth为100MB的记录
支持变更为包年/包月计费模式。 变更规格 支持变更实例规格。 支持变更实例规格。 回收站中实例是否计费 开启回收站策略的包年/包月实例，退订后会存入回收站中，此时不收取实例费用，但是会按需收取存储空间费用。 从回收站中恢复的包年/包月实例，计费模式会变为按需计费。 开启回收站策略的按需实例，删除后会存入回收站
如何扩总分区？ 增加基准带宽/代理数量，可以扩大总分区数。 在Kafka控制台的实例所在行，单击“更多 > 变更规格”，进入变更规格页面，根据实际情况扩容基准带宽/代理数量。具体操作请参考变更Kafka实例规格。 父主题： Topic和分区问题
AZ内实例容灾、实例数据多副本技术方案，保障服务的持久性和可靠性。 表1 DMS for Kafka可靠性架构 可靠性方案 简要说明 跨AZ容灾 DMS for Kafka提供跨AZ类型实例，支持跨AZ容灾，当一个AZ异常时，不影响Kafka实例持续提供服务。 AZ内实例容灾 同
project_id 是 String 项目ID，获取方式请参见获取项目ID。 connector_id 是 String 实例转储ID。 请参考查询实例返回的数据。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 source_type 是 String 源数据类型，目前只支持BLOB。
bootstrap_servers：实例连接地址与端口。 topic_name：Topic名称。 sasl_plain_username/sasl_plain_password：首次开启密文接入时设置的用户名与密码，或者创建用户时设置的用户名和密码。为了确保用户名和密码的安全性，建议对用户名和密码进行加密处理，使用时解密。
计费模式下的费用计算过程，请参见计费样例。 续费 包年/包月Kafka实例在到期后会影响Kafka实例的正常运行。如果您想继续使用Kafka实例，需要在规定的时间内为Kafka实例进行续费，否则Kafka实例、磁盘存储空间等资源将会自动释放，数据也可能会丢失。续费包括手动续费和自
权限管理 创建用户并授权使用DMS for Kafka
管理消息 查看Kafka消息 修改Kafka消息老化时间 删除Kafka消息 诊断Kafka消息积压
配置Topic 创建Kafka Topic 设置Kafka Topic权限 Topic管理
迁移数据 Kafka数据迁移概述 使用Smart Connect迁移数据
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
