-
与其他云服务的关系 - 分布式消息服务Kafka版
期为1分钟。 弹性公网IP（Elastic IP） 弹性公网IP提供独立的公网IP资源，包括公网IP地址与公网出口带宽服务。Kafka实例绑定弹性公网IP后，可以通过公网访问Kafka实例。 标签管理服务（Tag Management Service） 标签管理服务是一种快速便捷
-
快速连接Kafka并生产消费消息 - 分布式消息服务Kafka版
快速连接Kafka并生产消费消息 本章节将为您介绍分布式消息服务Kafka版入门的使用流程，以在“华北-北京四”区域创建并连接一个使用密文接入、安全协议为SASL_SSL的Kafka 2.7实例为例，帮助您快速上手Kafka。 您还可以通过API方式创建Kafka实例、在业务代码中连接Kafka实例。
-
扩容失败提示资源不足 - 分布式消息服务Kafka版
扩容失败提示资源不足 问题现象：扩容失败，提示底层ECS/EVS资源不足，但在ECS控制台可以购买对应规格的ECS。 可能原因：底层资源配额与控制台界面显示的可用规格配额存在差异。 解决方法：联系客服增加配额数。 父主题： 实例规格变更问题
-
使用客户端连接Kafka（密文接入） - 分布式消息服务Kafka版
4.0版本，确保Kafka实例版本与命令行工具版本相同。 已创建弹性云服务器，如果使用内网通过同一个VPC访问实例，请设置弹性云服务器的VPC、子网、安全组与Kafka实例的VPC、子网、安全组一致。在弹性云服务器中安装Java Development Kit 1.8.111或以
-
使用客户端连接Kafka（明文接入） - 分布式消息服务Kafka版
4.0版本，确保Kafka实例版本与命令行工具版本相同。 已创建弹性云服务器，如果使用内网通过同一个VPC访问实例，请设置弹性云服务器的VPC、子网、安全组与Kafka实例的VPC、子网、安全组一致。在弹性云服务器中安装Java Development Kit 1.8.111或以
-
选择和配置安全组 - 分布式消息服务Kafka版
使用内网通过同一个VPC访问实例 客户端和实例是否使用相同的安全组？ 是，如果保留了创建安全组后，系统默认添加的入方向“允许安全组内的弹性云服务器彼此通信”规则和出方向“放通全部流量”规则，则无需添加其他规则。否则，请添加表1所示规则。 表1 安全组规则 方向 协议 端口 源地址
-
在Windows服务器中无法登录Kafka Manager - 分布式消息服务Kafka版
在Windows服务器中无法登录Kafka Manager 问题现象 在Windows服务器的浏览器中输入Kafka Manager地址，无法登录Kafka Manager，报错信息如下图。 根因描述 Windows服务器和Kafka实例不在同一个VPC同一个子网内，或者安全组配置不正确，导致网络无法连通。
-
Kafka Manager概述 - 分布式消息服务Kafka版
Manager公网访问地址 在浏览器中输入Kafka Manager的地址，进入Kafka Manager登录页面。 如果是开启了公网访问，在本地浏览器输入Kafka Manager地址访问；如果没有开启公网访问，需要登录1的弹性云服务器，然后在浏览器输入Kafka Manager地址访问。
-
使用MirrorMaker跨集群同步数据 - 分布式消息服务Kafka版
emit.heartbeats.enabled true 连接器应定期发出心跳 emit.heartbeats.interval.seconds 5秒 心跳频率 emit.checkpoints.enabled true 连接器应定期发出消费端偏移量信息 emit.checkpoints
-
查询产品规格列表 - 分布式消息服务Kafka版
String Kafka实例的基准带宽。 available_zones Array 实例资源未售罄的可用区。 ecs_flavor_id String 该产品规格对应的虚拟机规格。 arch_type String 实例规格架构类型。当前仅支持X86。 表6 io参数说明 参数 类型
-
测试Kafka实例TPS - 分布式消息服务Kafka版
获取Kafka命令行工具2.7.2版本。 购买客户端服务器。 购买1台ECS服务器（区域、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致，Linux系统），具体步骤请参考购买弹性云服务器。 购买完成ECS后，需要在ECS中完成以下配置： 安装Java JDK，并配置JAVA_HOME与PATH环境变量。
-
测试Kafka生产速率和CPU消耗 - 分布式消息服务Kafka版
size变大16倍时，客户端消息生产速率增加，服务端CPU消耗减少。 同AZ生产和跨AZ生产相比，客户端消息生产速率增加，服务端CPU消耗也随之增加。 副本从1变成3时，客户端消息生产速率下降较多，服务端CPU消耗增加。 异步复制的Topic和同步复制的Topic相比，客户端消息生产速率增加，服务端CPU消耗也随之增加。
-
Python - 分布式消息服务Kafka版
息。 准备环境 Python 一般系统预装了Python。在命令行输入python，得到如下回显，说明Python已安装。 [root@ecs-test python-kafka]# python3 Python 3.7.1 (default, Jul 5 2020, 14:37:24)
-
变更Kafka实例规格 - 分布式消息服务Kafka版
请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在Kafka实例所在行，单击“更多 > 变更规格”，进入“分布式消息服务Kafka版变更规格”页面。 根据实际情况选择扩容存储空间、代理数量、代理规格、基准带宽，或者缩容代理规格。
-
Go - 分布式消息服务Kafka版
使用前请参考收集连接信息收集Kafka所需的连接信息。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 [root@ecs-test confluent-kafka-go]# go version go version go1.16.5 linux/amd64
-
产品规格 - 分布式消息服务Kafka版
1.0、2.7和3.x，Kafka实例分为集群版和单机版，集群版实例由三个及以上代理组成，单机版实例由一个代理组成。 实例规格以实例提供的ECS规格分类，具体如下： 集群版实例 kafka.2u4g.cluster.small kafka.2u4g.cluster kafka.4u8g
-
配置Kafka实例的公网访问 - 分布式消息服务Kafka版
在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 单击Kafka实例的名称，进入实例的“基本信息”页面。 在“公网访问”后，单击，开启公网访问。在“弹性IP地址”中，为每个代理设置对应的弹性IP地址，单击，跳转到“后台任务管理”页
-
查看Kafka审计日志 - 分布式消息服务Kafka版
查看Kafka审计日志 操作场景 通过云审计（Cloud Trace Service，CTS）服务，您可以记录与分布式消息服务Kafka版相关的操作事件，便于日后的查询、审计和回溯。 前提条件 已开通CTS。 CTS支持的DMS for Kafka操作 表1 云审计服务支持的DMS for Kafka操作列表
-
查询Kafka实例的协调器信息 - 分布式消息服务Kafka版
coordinators objects 所有消费组对应的协调器列表。 表3 coordinators 参数 参数类型 描述 group_id String 消费组ID。 id Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。
-
查询产品规格列表 - 分布式消息服务Kafka版
产品ID。 请求参数 无 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 engine String 分布式消息服务的产品类型。 versions Array of strings 支持的产品版本类型。 products Array of ListEngineProductsEntity
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
