检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
获取测试工具。 获取Kafka命令行工具2.7.2版本。 购买客户端服务器。 购买如下参数的2台ECS服务器,具体步骤请参考购买弹性云服务器。 区域、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致,规格为4U8G,Linux系统的ECS。 区域、虚拟私有云、子网、安全组与Kafka实
Kafka单机实例 Kafka单机实例规格 Kafka单机实例由一个代理组成,兼容开源Kafka 2.7版本,适用于测试场景,不建议用于生产业务。 关于下表中TPS的说明: TPS(Transaction per second):在Kafka场景中,指每秒能写入到Kafka实例的最大消息数量。
图解Kafka、RabbitMQ和RocketMQ的差异
Kafka实例是否支持修改访问端口? Kafka实例的访问端口固定,不支持修改。 如果是访问未开启SASL的Kafka实例 支持的访问方式如下:同一VPC内访问、公网访问、跨VPC访问和DNAT访问。 同一VPC内使用IPv4地址访问,访问端口为9092。 同一VPC内使用IPv6地址访问,访问端口为9192。
Kafka实例是否支持公网访问? Kafka实例支持公网访问。使用公网访问Kafka实例的具体操作,请参考连接实例。 父主题: 连接问题
Kafka实例是否支持无密码访问? 支持,连接明文接入的Kafka实例时,无需密码。具体操作,请参考使用客户端连接Kafka(关闭SASL)。 父主题: 连接问题
Smart Connect 修改转储任务的配额 创建关闭实例转储节点的订单 创建转储任务 查询转储任务列表 查询单个转储任务 删除单个转储任务 父主题: API V2
后台任务管理 查询实例的后台任务列表 - ListBackgroundTasks 查询后台任务管理中的指定记录 - ShowBackgroundTask 删除后台任务管理中的指定记录 - DeleteBackgroundTask 父主题: API V2(推荐)
生命周期管理 创建Kafka实例 - CreatePostPaidKafkaInstance 查询所有实例列表 - ListInstances 查询指定实例 - ShowInstance 删除指定的实例 - DeleteInstance 修改实例信息 - UpdateInstance
导出Kafka实例列表 分布式消息服务Kafka版支持在控制台导出实例列表信息,供用户查看和使用。 导出Kafka实例列表 登录Kafka控制台。 在管理控制台左上角单击,选择Kafka实例所在的区域。 通过以下任意一种方法,导出实例列表。 勾选待导出的实例,单击“导出 > 导出
使用控制台连接Kafka 本章节介绍Kafka实例如何在控制台生产消息。此功能通过将指定消息发送给Kafka实例,验证业务逻辑是否正常。 前提条件 仅在实例的“状态”为“运行中”时,才可以在Topic中生产消息。 已创建Topic。 在控制台生产消息 登录Kafka控制台。 在管
在Topic列表页面左上方单击“查看变更任务”,进入“后台任务管理 > 即时任务”页面,当任务的“状态”为“成功”时,表示分区平衡完成,即修改副本数成功。 定时任务 系统自动跳转到“后台任务管理 > 定时任务”页面,此页面的状态仅表示定时任务是否开始执行,并非表示任务是否执行成功。 当“状态”为“待执行”时,表示定时分区平衡任务未执行。
查看Kafka消费组信息 消费组创建成功后,可查看消费组配置信息和状态信息。 查看消费组列表 您可以在Kafka控制台查看消费组列表,也可以通过客户端查看消费组列表。 查看消费组列表(控制台) 查看消费组列表(Kafka客户端) 登录Kafka控制台。 在管理控制台左上角单击,选择Kafka实例所在的区域。
Topic是否支持ACL权限配置? Kafka实例已开启Kafka SASL_SSL功能,此时Topic支持配置ACL权限。在Kafka控制台的“实例管理 > Topic管理”页面,在需要设置用户权限的Topic所在行,单击“用户权限”,为用户设置不同的权限。 具体操作请参考设置Topic权限。
rorMaker,否则会导致数据在Topic内无限循环复制。 实施步骤 购买一台弹性云服务器,确保弹性云服务器与源集群、目标集群网络互通。具体购买操作,请参考购买弹性云服务器。 登录弹性云服务器,安装Java JDK,并配置JAVA_HOME与PATH环境变量,使用执行用户在用户家目录下修改“
关闭Kafka Manager Kafka Manager会占用额外的内存和CPU资源,关闭Kafka Manager可以减少这部分资源的占用。本章节指导您在控制台关闭Kafka Manager。 约束与限制 Kafka Manager关闭后,无法再次开启。 关闭Kafka Manager,不会重启实例。
页面上方直接提示修改结果。 内网访问 修改方法请参考配置Kafka实例的明文/密文接入。 系统跳转到“后台任务管理”页面,并显示当前任务的操作进度和结果。 公网访问 修改方法请参考配置Kafka实例的公网访问。 系统跳转到“后台任务管理”页面,并显示当前任务的操作进度和结果。 容量阈值策略 单
重置Manager密码失败,界面提示重置实例的密码失败,请重新尝试重置密码操作。如果多次重置失败,请联系客服处理。 只有所有代理都重置密码成功,系统才会提示重置密码成功,否则会提示重置失败。 相关文档 如果您希望通过API重置Kafka Manager密码,请参考重置Manager密码。
重启Kafka Manager 当Kafka Manager无法登录或者无法使用时,例如下图中的报错,可以通过重启Kafka Manager,使Kafka Manager恢复正常。 图1 报错信息 2023年5月17日及以后创建的实例不提供重启Kafka Manager功能。 约束与限制
导出Kafka Topic列表 本章节指导您在控制台导出Topic列表,支持批量导出。 前提条件 已创建Topic。 导出Topic列表 登录Kafka控制台。 在管理控制台左上角单击,选择Kafka实例所在的区域。 单击Kafka实例的名称,进入实例详情页面。 在左侧导航栏选择“实例管理