创建MNS Source Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流入任务，将 消息服务MNS 中的数据快速导入 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。...
将云消息队列 Kafka 版的数据迁移至MaxCompute
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...
开启ACL
云消息队列 Kafka 版 V2系列专业版 和V3系列Serverless 实例提供ACL功能，您可以在开启此功能后按需为SASL用户授权，通过SASL接入点接入实例。前提条件 实例规格类型为V2系列专业版 或V3系列Serverless版。实例运行状态为 服务中。实例大...
升级多可用区
前提条件 您使用的 云消息队列 Kafka 版 实例类型为 专业版。实例当前为单可用区部署。实例当前读写流量水位没有接近购买规格峰值。实例大版本必须为2.2.0或以上版本，小版本建议您使用最新版本。升级影响 该操作服务不会中断，但可能导致...
【通知】V2系列Serverless实例退市公告
云消息队列 Kafka 版 V2系列Serverless实例将于2024年02月28日正式下线，如您目前仍在使用此类型实例，请尽快迁移至V3系列Serverless实例。停止维护 感谢您对 云消息队列 Kafka 版 V2系列Serverless实例的支持！为了提供更稳定、更高性能的...
访问链接与端口
开启公网 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，在 实例列表 页面单击目标实例名称。在左侧导航栏，单击 访问链接与端口。在目标服务右侧，打开 开启 开关，为服务开启公网。说明 开启...
云监控
message_accumulation_onetopic userId、instanceId、consumerGroup、topic count 查看云监控数据 查看监控数据的步骤如下：登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例...
购买和部署实例
获取云消息队列 Kafka 版访问授权。步骤一：购买实例 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，然后单击 购买实例。在 请选择您要创建的实例的付费方式 面板，选择 实例系列 为 Confluent ...
创建前提
AliyunKafkaFullAccess：管理 云消息队列 Kafka 版 的权限。AliyunFCFullAccess：管理 函数计算FC（Function Compute）的权限。AliyunEventBridgeFullAccess：管理 事件总线EventBridge 的权限。目标服务的管理权限。除上述必要权限外，如...
实例支持哪些开源版本？
云消息队列 Kafka 版 标准版与专业版实例支持的开源版本是2.2.0、2.6.2版本，同时兼容对应的2.2.x、2.6.x的客户端。您在购买实例后，可在部署实例时选择2.2.0或2.6.2版本。建议您使用2.2.0及以上的版本。如需升级版本，请参见 升级实例版本...
搭配云HBase和Spark构建一体化数据处理平台
消息流入：Flume、Logstash或者在线库的Binlog流入 云消息队列 Kafka 版。实时计算：通过X-Pack Spark Streaming实时地消费 云消息队列 Kafka 版 的消息，写入到云HBase中对外提供在线查询。实时存储与检索：云HBase融合Solr以及Phoenix ...
为什么限制Topic总数（分区总数）？
Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。
RAM跨云账号授权
背景信息 企业A开通了 云消息队列 Kafka 版，该企业需要企业B代为操作 云消息队列 Kafka 版 的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为 云消息队列 Kafka 版 所有者。企业A希望可以授权企业B来...
云消息队列 Kafka 版支持被审计的事件说明
云消息队列 Kafka 版 已与操作审计服务集成，您可以在操作审计中查询操作 云消息队列 Kafka 版 产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。事件...
ACL授权
ACL授权 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在 实例列表 页面，单击目标实例名称。在左侧导航栏，选择 用户管理，单击目标用户右侧 操作 列的 授权。配置项 说明 资源类型 实例：对集群授权。Topic：对某一个...
为什么消息已经过期还未被删除？
问题现象 您发送的消息在服务端...磁盘容量充足，使用率低于75%，云消息队列 Kafka 版 设置的集中清理消息的时间还未到，消息不会被删除。说明 磁盘使用率低于75%时，在每天凌晨4点，云消息队列 Kafka 版 集中删除超过 消息保留时长 的消息。
使用Kafka Connect将MySQL数据同步至云消息队列 Kafka...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
实例规格
本文说明 云消息队列 Kafka 版 支持的规格类型，以便您根据实际业务需求选择合适的实例规格。实例规格类型 云消息队列 Kafka 版 实例规格类型如下：项目 标准版（高写版）专业版（高写版）专业版（高读版）版本 支持部署2.x版本。如需升级...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
云监控
查看云监控数据 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在左侧导航栏，选择 可观测>云监控。在 云监控 页面，单击 报警规则 页签，单击要查看监控数据的资源页签...
续费操作
登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 概览 区域右上角的 续费。在 续费 面板，选择购买时长，并选中 消息队列 Kafka（包年包月）服务...
服务关联角色
本文介绍 云消息队列 Kafka 版 服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...
管理预警联系人
添加预警联系人 登录 云消息队列 Kafka 版 控制台。在左侧导航栏，选择 常用工具/链接>预警联系人。在 预警联系人 页面，单击 添加联系人。在 添加联系人 面板，填写以下信息，然后单击 确定。参数 描述 姓名 联系人姓名。手机号码 联系人...
创建FC Sink Connector
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已开通函数计算服务，具体操作，请参见 开通服务。开通事件总线EventBridge并授权。什么是函数计算？函数计算...
默认配置映射关系
目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 消息服务MNS 部分事件$.data.messageBody 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body 数据传输服务DTS 部分事件$.data 云消息队列 ...
默认配置映射关系
目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 消息服务MNS 部分事件$.data.messageBody 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body 数据传输服务DTS 部分事件$.data 云消息队列 ...
默认配置映射关系
目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 消息服务MNS 部分事件$.data.messageBody 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body 数据传输服务DTS 部分事件$.data 云消息队列 ...
为什么购买了按量付费实例后不使用也要收费？
按量付费模式与购买后是否实际使用无关。您在购买 云消息队列 Kafka 版 按量付费实例后，系统会为您分配相应的实例资源。因此，按量付费模式是以实例单价×服务时间计费的，与您购买后是否使用该实例无关。
用户管理
查看用户列表 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击左侧操作栏的 用户管理，查看所有用户列表。新增用户 在 用户管理 页面，单击 添加LDAP用户。在...
续费操作
登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 概览 区域右上角的 续费。在 续费 面板，选择购买时长，并选中 消息队列 Kafka（包年包月）服务...
基本概念
Connector 云消息队列 Kafka 版 的组件，用于 云消息队列 Kafka 版 和其他阿里云服务之间的数据同步。更多信息，请参见 Connector概述。标签 用于识别 云消息队列 Kafka 版 资源。您可以将作用相同的 云消息队列 Kafka 版 的资源归类，便于...
内容分割
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
Kafka触发器
partition Int 1 云消息队列 Kafka 版 的消费分区信息。offset Int 0 云消息队列 Kafka 版 的消息位点。timestamp String 1655952591589 开始消费时间戳。步骤三：编写函数代码并测试 触发器创建完成后，您可以开始编写并测试函数代码，以...
内容映射
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
如何处理不活跃的Topic
上述2个关键指标可通过下列2种方式获取：通过管理控制台查看Topic信息 登录 云消息队列 Kafka 版 控制台。在顶部菜单栏，选择地域。在左侧导航栏，单击 实例列表，单击需要查询的Kafka实例名称。在实例详情页面，单击左侧导航栏中的 Topic...
如何选择实例规格？
云消息队列 Kafka 版 提供两种实例规格类型：标准版和专业版。您可以根据自建迁移情况选择实例规格。标准版 流量规格：集群流量的总量÷3（优化）磁盘大小：流量均值×存储时长×3（备份）分区数量：根据实际业务需求 说明 建议您在迁移...
新增分区时对应的Topic数量额度
可使用的Topic数量与总分区数强相关。例如，您已购买了分区数为50、流量规格为alikafka.hw.2xlarge、规格内赠送分区数为1000的实例，那么该...云消息队列 Kafka 版 Serverless实例不受此项限制。购买分区的操作步骤，请参见 升级实例配置。
内容富化
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
标签管理
本文介绍如何为 云消息队列 Kafka 版 的实例、Topic、Group 等资源绑定标签，从而帮助您根据标签给资源归类，高效管理资源。背景信息 标签由标签键和标签值组成，可以标记 云消息队列 Kafka 版 的资源。如果您的账号下有多种 云消息队列 ...
自动创建Topic
云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，不建议在生产环境中开启自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过...
- 产品推荐
- 这些文档可能帮助您