云消息队列 Kafka 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 Kafka 版 中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源...
云消息队列 Kafka 版
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将 云消息队列 RabbitMQ 版 的数据导出至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您...
消息队列Kafka版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 ...
云消息队列 Kafka 版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流入任务，实现将 云消息队列 Kafka 版 中的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
消息队列Kafka版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入源为 云消息队列 Kafka 版 的消息流入任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 Kafka...
消息队列Kafka版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的数据流出至 云消息队列 Kafka 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建...
什么是云消息队列 Kafka 版？
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...
消息队列Kafka
连接 云消息队列 Kafka 版 集群 云消息队列 Kafka 版 集群已创建。详情请参见 创建资源。实时计算Flink与Kafka集群处于同一VPC内，且 云消息队列 Kafka 版 已对Flink开放白名单。可参见 配置白名单 来配置 云消息队列 Kafka 版 的白名单。...
云消息队列 Kafka 版服务等级协议
云消息队列 Kafka 版 规定了阿里云向客户提供的阿里云 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案。如需查看 云消息队列 Kafka 版 的服务可用性等级指标及赔偿方案，请参见 云消息队列 Kafka 版服务等级协议。
什么是云消息队列 Kafka 版？
三分钟了解阿里云 云消息队列 Kafka 版。
云消息队列 Kafka 版
MQ_INST_115964845466*_ByBeUp3p Topic 选择生产 云消息队列 Kafka 版 消息的Topic。topic Group ID 选择源实例的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。GID_http_1 消费位点 ...
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
如何通过代理访问云消息队列 Kafka 版实例
概述 暂不支持通过代理访问云消息队列 Kafka 版实例，具体请查看 详细信息。详细信息 云消息队列 Kafka 版的客户端访问服务端的原理如下。通过 bootstrap.servers 随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的消息收发。...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
如何快速使用云消息队列 Kafka 版的Java SDK收发消息
六分钟上手 云消息队列 Kafka 版。文档教程 快速入门
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
云消息队列 Kafka 版自定义权限策略参考
本文介绍 云消息队列 Kafka 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来...
将云消息队列 Kafka 版接入阿里云Elasticsearch
云消息队列 Kafka 版 云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。更...
能否通过公网访问云消息队列 Kafka 版实例？
网络类型为公网/VPC的 云消息队列 Kafka 版 实例支持通过公网访问。云消息队列 Kafka 版 提供VPC和公网/VPC两种网络类型的实例。如需通过公网访问，请购买公网/VPC实例。如果已购买VPC实例，请升级实例配置，变更VPC实例为公网/VPC实例。更...
无法ping通云消息队列 Kafka 版的接入点
问题描述 无法ping通云消息队列 Kafka 版的接入点。本地客户端无法telnet Kafka或提示连接超时（Connection timed out）。问题原因 为了保证安全，云消息队列 Kafka 版集群默认禁ping。连接VPC接入点时，客户端与Kafka不在同一VPC下。解决...
使用Kafka Connect将SQL Server数据同步至云消息队列 ...
本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至 云消息队列 Kafka 版。前提条件 在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...
云消息队列 Kafka 版支持被审计的事件说明
云消息队列 Kafka 版 已与操作审计服务集成，您可以在操作审计中查询操作 云消息队列 Kafka 版 产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。事件...
使用Kafka Connect将MySQL数据同步至云消息队列 Kafka...
本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出 云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...
为什么不能登录部署云消息队列 Kafka 版的机器？
云消息队列 Kafka 版 提供全托管免运维服务，您无需登录机器。云消息队列 Kafka 版 是全托管的，由 云消息队列 Kafka 版 专业团队进行运维保障，您无需登录机器。集群的一些基础信息会通过监控告警进行透传。
将云消息队列 Kafka 版的数据迁移至MaxCompute
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...
如何快速测试云消息队列 Kafka 版服务端是否正常？
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
路由到云消息队列 Kafka 版
本文介绍如何在 事件总线EventBridge 控制台添加 云消息队列 Kafka 版 作为事件流中的服务类型。前提条件 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 购买和部署...
客户端首次接入云消息队列 Kafka 版时出现异常的排查...
详细信息 客户端首次接入云消息队列 Kafka 版时如果出现异常，您可以通过以下三个方面进行排查：网络连通问题：通常有如下几种情况可能会导致网络不通，客户端无法连接云消息队列 Kafka 版的服务端。ECS实例（客户端）与云消息队列 Kafka ...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
数据转发到消息队列Kafka
您可以使用规则引擎，将物联网平台数据转发到消息队列（Kafka）中存储，从而实现消息从设备、物联网平台、Kafka到应用服务器之间的全链路高可靠传输能力。...在 消息队列Kafka版 控制台 对应实例的 Topic详情 页面，查询流转的消息。
使用云消息队列 Kafka 版时客户端的报错及解决方案
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
数据转发到消息队列Kafka
您可以使用规则引擎，将物联网平台数据转发到消息队列（Kafka）中存储，从而实现消息从设备、物联网平台、Kafka到应用服务器之间的全链路高可靠传输能力。...在 消息队列Kafka版 控制台 对应实例的 Topic详情 页面，查询流转的消息。
不在同一可用区内的ECS实例如何访问云消息队列 Kafka ...
详细信息 以非公网的方式访问云消息队列 Kafka 版实例时，必须满足以下两个条件：ECS实例与云消息队列 Kafka 版实例在同一VPC网络实例内。如果ECS实例和云消息队列 Kafka 版实例不在同一个VPC网络实例内，请根据实际情况，重新创建或部署...
配置消息队列Kafka版实例的参数
本文为您介绍目标数据库实例为 专线/VPN网关/智能网关 方式接入的 阿里云消息队列Kafka版 时，部分特殊参数的配置方法和获取方式。注意事项 使用此方案将 阿里云消息队列Kafka版 接入DTS，会将数据写入到您指定的节点中。若您的源库为MySQL...
消息队列Kafka版系统权限策略参考
本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）...
使用云消息队列 Kafka 版时出现“Not authorized to ...
问题描述 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...
使用Debezium将MySQL数据同步至云消息队列 Kafka 版
本文介绍如何创建Debezium MySQL Source Connector，将MySQL的数据同步至 云消息队列 Kafka 版。前提条件 已开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台创建存储空间。已开通...
自定义事件源消息队列Kafka版
前提条件 消息队列Kafka版 购买和部署消息队列Kafka版实例 创建Topic、Group 事件总线EventBridge 开通事件总线EventBridge并授权 创建自定义总线 操作步骤 登录 事件总线EventBridge 控制台，在左侧导航栏，单击 事件总线。在顶部菜单栏，...
- 产品推荐
- 这些文档可能帮助您