本文介绍如何使用MirrorMaker将自建Kafka集群的数据迁移到 云消息队列 Kafka 版 集群。前提条件 您已完成以下操作:下载迁移工具MirrorMaker 迁移Topic上云 背景信息 Kafka的镜像特性可实现Kafka集群的数据备份。实现这一特性的工具就是...
本文介绍 云消息队列 Kafka 版 的计费方式,帮助您快速了解计费详情,按需选择计费方式。说明 云消息队列 Kafka 版 的Connector组件依赖于 事件总线,云消息队列 Kafka 版 不会额外收取费用。事件总线 的计费说明,请参见 计费说明。同时,...
本文介绍如何在 云消息队列 Kafka 版 控制台完成实例升配,升级的配置项包括规格类型、流量规格、磁盘容量及分区规格等。前提条件 实例处于 服务中 或 未部署 状态。实例中没有进行中的Topic引流任务。注意事项 升级实例配置会引发集群逐台...
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将自建Kafka集群的 Group 迁移到 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka 版 ...
本文汇总了 云消息队列 Kafka 版 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议
通过数据传输服务DTS(Data Transmission Service),您可以将自建MySQL同步至 云消息队列 Kafka 版,扩展消息处理能力。前提条件 您已完成以下操作:自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
问题描述 无法ping通云消息队列 Kafka 版的接入点。本地客户端无法telnet Kafka或提示连接超时(Connection timed out)。问题原因 为了保证安全,云消息队列 Kafka 版集群默认禁ping。连接VPC接入点时,客户端与Kafka不在同一VPC下。解决...
概述 暂不支持通过代理访问云消息队列 Kafka 版实例,具体请查看 详细信息。详细信息 云消息队列 Kafka 版的客户端访问服务端的原理如下。通过 bootstrap.servers 随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的消息收发。...
前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且该实例必须满足以下条件:项目 说明 状态 服务中。版本 大版本为2.2.0,且小版本为最新版本。说明 您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面的 基础信息 区域查看实例的...
映射关系如下:消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
如果您对 云消息队列 Kafka 版 服务的消费情况产生疑问,可以查看消费明细。查看费用账单 登录 云消息队列 Kafka 版 控制台。在页面右上角,选择 费用>用户中心。在左侧导航栏,按需选择 账单管理 目录下的账单维度,查看您的消费信息。月...
映射关系如下:消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
在某个实例下发起重启类任务(包括配置变更、版本升级、开启ACL、实例升配)后,您可以在 云消息队列 Kafka 版 控制台查看重启类任务的执行记录,帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件 创建并部署 云消息队列 Kafka 版 ...
映射关系如下:消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
本文介绍 云消息队列 Kafka 版 的SDK和API及Terraform的支持情况,供您进行对应的开发操作。开发参考 API参考指南 SDK参考 Terraform
云存储和Local存储。云消息队列 Kafka 版 实例支持云存储和Local存储。详情请参见 存储引擎对比。
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将某个 云消息队列 Kafka 版 实例的Topic迁移到另一个 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云...
针对各种业务需求,云消息队列 Kafka 版 提供相关的实践教程,您可以根据本文查看适合您业务的实践教程文档。实践教程 最佳实践 生态对接
在某个实例下发起重启类任务(包括实例升降配、定时任务)后,您可以在 云消息队列 Kafka 版 控制台查看该实例的重启类任务的执行记录,获取任务的类型、开始执行时间、结束执行时间、状态等信息。前提条件 创建并部署 云消息队列 Kafka 版...
Knative已支持Kafka事件源,您可将Knative与 云消息队列 Kafka 版 对接,在Knative上实现Kafka消息推送。前提条件 部署Knative 购买并部署 云消息队列 Kafka 版 实例 重要 云消息队列 Kafka 版 实例和Knative必须处于同一VPC内。云消息队列...
在 交换机 页面,查看以下信息:交换机 实例ID/名称 专有网络 可用区 说明 请根据该页面的可用区(A~G)在 云消息队列 Kafka 版 控制台中选择对应的可用区(A~G)。例如,某VPC交换机(vSwitch)显示在 可用区B,那么在 云消息队列 Kafka...
名称 类型 描述 示例值 object EventBridge 消息队列 Kafka 版的自定义事件源参数 ConsumerGroup string 订阅该 Topic 的消费者所对应的 Group ID。DEFAULT_GROUP InstanceId string 消息队列 Kafka 版的实例的 ID。r-8vb64581862c*Network...
问题现象 在 云消息队列 Kafka 版 控制台 的 Group 管理 页面删除Group后,此Group的状态一直处于 删除中。可能原因 Group中存在活跃的订阅关系。Group上有消费线程在提交新的消费位点。解决方案 登录 云消息队列 Kafka 版 控制台,查看...
欠费预警接收设置 登录 云消息队列 Kafka 版 控制台。单击页面右上方的 图标,进入 消息中心 页面。在左侧导航栏,单击 基本接收管理。在 基本接收管理 页面的 消息类型 中勾选 产品的欠费、停服、即将释放相关信息通知,单击 修改。在 ...
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面,您已成功创建Topic,但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...
ALIYUN:ESS:ScalingGroup 函数计算FC ALIYUN:FC:Service 消息队列Kafka版 ALIYUN:KAFKA:Instance 云数据库MongoDB版 ALIYUN:MONGODB:Instance ALIYUN:MONGODB:ServerlessInstance ALIYUN:MONGODB:ShardingInstance 文件存储NAS ALIYUN:NAS:...
DBInstance ALIYUN:GPDB:ElasticDBInstance API网关API Gateway ALIYUN:ApiGateway:Instance 数据传输服务DTS ALIYUN:DTS:SubscriptionInstance ALIYUN:DTS:SynchronizationJob ALIYUN:DTS:MigrationJob 消息队列Kafka版 ALIYUN:KAFKA:...
可能原因 老版 云消息队列 Kafka 版 实例不支持报警数据上报。解决方案 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域,选择地域。在 实例列表 页面,单击目标实例名称。在 实例详情 页面,单击 配置信息 页签,然后单击...
您可以直接在 云消息队列 Kafka 版 控制台进行发送消息的测试。您可以在控制台的 Topic管理 页面,单击目标Topic右侧的 发送消息,进行消息发送测试,以验证集群是否运转正常。
如果您的 云消息队列 Kafka 版 实例的公网流量消耗远小于购买的公网流量配置,或者分区的使用量远小于购买的分区数量,您可以降低公网流量和分区数量配置,从而节约成本。本文介绍如何在 云消息队列 Kafka 版 控制台降低实例的公网流量、...
自动创建Topic是指当 云消息队列 Kafka 版 实例发送请求以获取不存在的Topic元数据时,例如向不存在的Topic发送生产请求,云消息队列 Kafka 版 可以自动创建Topic。自动创建Topic适用于迁移上云场景或测试场景,无需手动重复创建Topic,...
背景信息 Rebalance是 云消息队列 Kafka 版 对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户端出现Rebalance可能是以下原因:当消费者主动新增订阅或者取消订阅时,会触发该Consumer Group内的Rebalance。当Topic的...
问题现象 您已启动某个Group的消费线程,但在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签,查不到Topic被Group订阅的信息,或者在 Group 详情 页面的 消费状态 页签,查不到该Group订阅的Topic信息。可能原因 客户端...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前,请确保您已完成以下操作:已下载SQL Server Source Connector。具体信息,请参见 SQL Server Source ...
云消息队列 Kafka 版 专业版实例提供ACL功能,您可以在开启此功能后按需为SASL用户授权,通过SASL接入点接入实例。前提条件 实例规格类型为 专业版。实例运行状态为 服务中。实例大版本为2.2.0版本及以上。如何升级实例大版本,请参见 升级...
云消息队列 Kafka 版 V2系列Serverless实例将于2024年02月28日正式下线,如您目前仍在使用此类型实例,请尽快迁移至V3系列Serverless实例。停止维护 感谢您对 云消息队列 Kafka 版 V2系列Serverless实例的支持!为了提供更稳定、更高性能的...
本文介绍 云消息队列 Kafka 版 支持对接的生态。阿里云生态 云数据库HBase版 基于HBase和Spark的数据处理平台 阿里云实时计算Flink 基于Flink的资讯场景实时数仓 大数据计算服务MaxCompute 接入MaxCompute 数据传输服务DTS 使用DTS同步...
当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将 云消息队列 Kafka 版 接入阿里云Elasticsearch的操作方法。前提...
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC...
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC接入。下载并安装Logstash。具体操作,请...