前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例运行状态处于 服务中 或 未部署。具体操作,请参见 步骤二:购买和部署实例。注意事项 按量计费转包年包月的过程中,实例始终处于服务中状态,不会因为实例重启而导致服务短暂不...
消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body 数据传输服务DTS ...
前提条件 云消息队列 Kafka 版 实例的状态为 服务中。背景信息 升级大版本 升级大版本是指跨版本升级,例如将 云消息队列 Kafka 版 实例的版本从0.10.x版本升级至2.x版本。重要 目前新部署实例仅支持2.x版本,存量0.10.x可正常使用。由于2....
添加预警联系人 登录 云消息队列 Kafka 版 控制台。在左侧导航栏,选择 常用工具/链接>预警联系人。在 预警联系人 页面,单击 添加联系人。在 添加联系人 面板,填写以下信息,然后单击 确定。参数 描述 姓名 联系人姓名。手机号码 联系人...
本文介绍 云消息队列 Kafka 版 服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下,为了完成自身的某个功能,需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
云消息队列 Kafka 版 对某些具体指标进行了约束和规范,您在使用 云消息队列 Kafka 版 时注意不要超过相应的限制值,以免程序出现异常。重要 若由于您的实例配置超出使用限制导致的任何不稳定情况,不在SLA承诺和赔偿范围内。云消息队列 ...
按量付费模式与购买后是否实际使用无关。您在购买 云消息队列 Kafka 版 按量付费实例后,系统会为您分配相应的实例资源。因此,按量付费模式是以实例单价×服务时间计费的,与您购买后是否使用该实例无关。
名称 类型 描述 示例值 object EventBridge 消息队列 Kafka 版的自定义事件源参数 ConsumerGroup string 订阅该 Topic 的消费者所对应的 Group ID。DEFAULT_GROUP InstanceId string 消息队列 Kafka 版的实例的 ID。r-8vb64581862c*Network...
云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示,一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka 版 的系统架构 Producer 通过push模式向 云消息队列 Kafka 版...
查看用户列表 登录 云消息队列 Kafka 版 控制台,在左侧导航栏,单击 实例列表。在 实例列表 页面,单击目标实例名称。在 实例详情 页面,单击左侧操作栏的 用户管理,查看所有用户列表。新增用户 在 用户管理 页面,单击 添加LDAP用户。在...
本文介绍如何在 云消息队列 Kafka 版 控制台完成实例升配,升级的配置项包括规格类型、流量规格、磁盘容量及分区规格等。前提条件 实例处于 服务中 或 未部署 状态。实例中没有进行中的Topic引流任务。注意事项 升级实例配置会引发集群逐台...
您可以从网络连通、客户端版本、配置这三个方向进行排查。您的客户端首次接入 消息队列Kafka版,通常会被以下三个问题困扰:网络连通 客户端版本 配置 您可以从上述三个方向,一步一步排查,基本上可以解决99%的问题。
本文介绍如何创建使用Tablestore Sink Connector,您可通过Tablestore Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至Tablestore的表中。前提条件 创建资源及授权策略,请参见 创建前提。创建Connector时生成的函数...
本文介绍如何应用 事件总线EventBridge 的事件流功能实现 云消息队列 Kafka 版 的消息路由。前提条件 已 开通事件总线EventBridge并授权。已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 购买和部署...
自动创建的实例和数据表名称格式如下:实例名称:kfk-{ 云消息队列 Kafka 版 实例名称后12位字符} 数据表表名:{Topic名称}:kafka_topic_{Topic名称}_{6位随机字符} 每个开通消息检索的Topic会在 云消息队列 Kafka 版 实例中自动创建4个...
迁移类型包括:通过命令行迁移 迁移Topic上云 迁移Group上云 迁移数据上云 通过元数据文件迁移上云 迁移自建Kafka集群至新实例 位点迁移 重要 目前不支持将自建Kafka集群的位点迁移到 云消息队列 Kafka 版。操作步骤 重要 云消息队列 Kafka...
本文介绍如何创建使用OSS Sink Connector,您可以通过OSS Sink Connector将数据从 云消息队列 Kafka 版 的数据源Topic导出至对象存储OSS的Object中。前提条件 详细步骤,请参见 创建前提。注意事项 Connector基于事件被处理的时间做时间...
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 Kafka 版 作为事件流中的事件提供方。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 购买和...
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面,您已成功创建Topic,但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC...
本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 并收发消息。前提条件 安装1.8或以上版本JDK。安装2.5或以上版本Maven。下载 kafka-spring-stream-demo,并将其上传在准备好的Linux操作系统。确保您的 云消息队列 Kafka 版 ...
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC接入。下载并安装Logstash。具体操作,请...
本文介绍如何使用MirrorMaker将自建Kafka集群的数据迁移到 云消息队列 Kafka 版 集群。前提条件 您已完成以下操作:下载迁移工具MirrorMaker 迁移Topic上云 背景信息 Kafka的镜像特性可实现Kafka集群的数据备份。实现这一特性的工具就是...
前提条件 创建并部署 云消息队列 Kafka 版 V3系列实例,且实例处于 服务中 状态。弹性能力 为应对生产环境中多阶梯的流量需求,云消息队列 Kafka 版 V3系列Serverless实例提供弹性伸缩流量规格的能力,您可以通过升配和降配修改发送、订阅...
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 Kafka 版 实例中。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买...
本文介绍如何在 云消息队列 Kafka 版 控制台完成实例升配或降配,配置项包括规格类型、实例类型、发送能力预留和订阅能力预留等。前提条件 实例处于 服务中 或 未部署 状态。升降配说明 为保障在预留规格生效时间内升配或者降配至预设容量...
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。更多信息,请参见 VPC...
迁移类型包括:通过命令行迁移 迁移Topic上云 迁移Group上云 迁移数据上云 通过元数据文件迁移上云 迁移自建Kafka集群至新实例 操作步骤 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域,选择地域。在 实例列表 页面,...
升级Broker可能产生以下影响:升级过程中,会逐个重启 云消息队列 Kafka 版 集群中所有的Broker。在重启Broker的过程中服务不会中断,但是从每个Broker重启完成之后的5分钟内消费的分区消息可能会发生乱序。重启过程中已有的客户端连接可能...
消息队列 Kafka 版优化了 PLAIN 机制,支持不重启实例的情况下动态增加 SASL 用户。scram:一种用户名密码校验机制,安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。默认值为 plain。plain Mechanism string 否 加密方式。...
本文介绍如何在 云消息队列 Kafka 版 控制台创建流入任务,将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和...
登录 云消息队列 Kafka 版 控制台,在 概览 页面的 资源分布 区域,选择地域。在左侧导航栏,选择 Connector生态集成>消息流入(Source)或者 Connector生态集成>消息流出(Sink)。在 消息流入(Source)或者 消息流出(Sink)页面,找到...
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 ...
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 ...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务,将 云消息队列 RocketMQ 版 的数据快速导入至 云消息队列 Kafka 版。前提条件 您已购买Kafka实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。您已...
在使用云消息队列 Kafka 版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权(sasl.mechanisms)...
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 ...
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 ...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前,请确保您已完成以下操作:已下载SQL Server Source Connector。具体信息,请参见 SQL Server Source ...