验证迁移结果

迁移成功后,目标 云消息队列 Kafka 实例下会创建对应的Topic和 Group。您可以在 Topic 管理 和 Group 管理 页面的列表中查看。前提条件 您已将自建Kafka集群迁移至 云消息队列 Kafka 实例中。迁移类型包括:通过命令行迁移 迁移...

从自建MySQL同步至云消息队列 Kafka

通过数据传输服务DTS(Data Transmission Service),您可以将自建MySQL同步至 云消息队列 Kafka ,扩展消息处理能力。前提条件 您已完成以下操作:自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...

通过元数据文件迁移上云

本文介绍如何在 云消息队列 Kafka 控制台创建迁移任务,将元数据迁移至 云消息队列 Kafka 已有实例。前提条件 下载JDK 8 购买并部署 云消息队列 Kafka 实例:购买并部署VPC实例 购买并部署公网/VPC实例 背景信息 Kafka集群元数据...

是否支持延迟消息

和开源Apache Kafka一样,云消息队列 Kafka 同样不支持延迟消息。

接入Filebeat

本文介绍如何将 云消息队列 Kafka 接入Filebeat。Filebeat Filebeat是用于转发和集中日志数据的轻量级传输程序。Filebeat可以监听指定的日志文件或位置,从中收集日志事件并将其转发到Elasticsearch或Logstash进行索引。Filebeat的工作...

迁移Group上云

本文介绍如何使用 云消息队列 Kafka 提供的迁移工具将自建Kafka集群的 Group 迁移到 云消息队列 Kafka 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka ...

如何快速使用云消息队列 Kafka 的Java SDK收发消息

六分钟上手 云消息队列 Kafka 。文档教程 快速入门

能否通过公网访问云消息队列 Kafka 实例?

网络类型为公网/VPC的 云消息队列 Kafka 实例支持通过公网访问。云消息队列 Kafka 提供VPC和公网/VPC两种网络类型的实例。如需通过公网访问,请购买公网/VPC实例。如果已购买VPC实例,请升级实例配置,变更VPC实例为公网/VPC实例。更...

如何通过代理访问云消息队列 Kafka 实例

概述 暂不支持通过代理访问云消息队列 Kafka 实例,具体请查看 详细信息。详细信息 云消息队列 Kafka 的客户端访问服务端的原理如下。通过 bootstrap.servers 随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的消息收发。...

接入点对比

云消息队列 Kafka 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;需要链路加密和消息鉴权,建议使用SSL...

使用云消息队列 Kafka 时出现“Not authorized to ...

问题描述 使用云消息队列 Kafka 时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时会遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 的控制台...

不在同一可用区内的ECS实例如何访问云消息队列 Kafka ...

详细信息 以非公网的方式访问云消息队列 Kafka 实例时,必须满足以下两个条件:ECS实例与云消息队列 Kafka 实例在同一VPC网络实例内。如果ECS实例和云消息队列 Kafka 实例不在同一个VPC网络实例内,请根据实际情况,重新创建或部署...

为什么需要升级实例来支持监控告警功能?

在控制台上可以查看和设置监控告警功能,但是在2018年11月以前部署的 云消息队列 Kafka 集群不支持上报监控告警数据,因此需要升级旧版本的 云消息队列 Kafka 实例集群,让它可以上报监控告警数据。若您要升级您的 云消息队列 Kafka ...

无法ping通云消息队列 Kafka 的接入点

问题描述 无法ping通云消息队列 Kafka 的接入点。本地客户端无法telnet Kafka或提示连接超时(Connection timed out)。问题原因 为了保证安全,云消息队列 Kafka 集群默认禁ping。连接VPC接入点时,客户端与Kafka不在同一VPC下。解决...

上迁移Topic

本文介绍如何使用 云消息队列 Kafka 提供的迁移工具将某个 云消息队列 Kafka 实例的Topic迁移到另一个 云消息队列 Kafka 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 ...

为什么额外增加分区要收费?

云消息队列 Kafka 优化了集群增加大量分区后带来的性能下降问题。自建开源Apache Kafka集群分区数大于1000后,集群性能开始急剧下降,遭遇性能瓶颈。阿里云 云消息队列 Kafka 对此进行了优化,单个集群的分区数理论上没有上限。但...

自由使用Group

前提条件 您已购买并部署 云消息队列 Kafka 实例,且该实例必须满足以下条件:项目 说明 状态 服务中。版本 大版本为2.2.0,且小版本为最新版本。说明 您可以在 云消息队列 Kafka 控制台的 实例详情 页面的 基础信息 区域查看实例的...

查看消费明细

如果您对 云消息队列 Kafka 服务的消费情况产生疑问,可以查看消费明细。查看费用账单 登录 云消息队列 Kafka 控制台。在页面右上角,选择 费用>用户中心。在左侧导航栏,按需选择 账单管理 目录下的账单维度,查看您的消费信息。月...

元数据导入

本文介绍如何在 云消息队列 Kafka 控制台创建元数据导入任务,将元数据迁移至 云消息队列 Kafka 已有实例。前提条件 下载JDK 8 购买并部署云消息队列 Kafka 实例:购买并部署VPC实例 购买并部署公网/VPC实例 说明 购买实例的规格可...

创建RabbitMQ Source Connector

本文介绍如何在 云消息队列 Kafka 控制台创建流入任务,将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 Kafka 。前提条件 您已购买 云消息队列 Kafka 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和...

创建MQTT Source Connector

本文介绍如何在 云消息队列 Kafka 控制台创建流入任务,将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 Kafka 实例中。前提条件 您已购买 云消息队列 Kafka 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买...

服务支持

本文汇总了 云消息队列 Kafka 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议

为什么Group不存在但能消费消息

问题现象 我在 云消息队列 Kafka 控制台 上,未查看到对应的Group,但此Group下却有消费线程在消费消息。可能原因 如果客户端使用 assign 方式消费消息,那么即使不创建Group,也可能消费消息。如果客户端使用 subscribe 方式消费消息,...

配置白名单

您可以设置访问 云消息队列 Kafka 的白名单,配置在白名单中的IP地址与端口才允许访问 云消息队列 Kafka 实例。前提条件 您已购买 云消息队列 Kafka 实例,且该实例处于 服务中 的状态。注意事项 公网/VPC类型的实例默认白名单为0...

默认配置映射关系

目标端类型 模式 值 云消息队列 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 部分事件$.data.value 消息服务MNS 部分事件$.data.messageBody 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body 数据传输服务DTS 部分事件$.data 云消息队列 ...

查看任务执行记录

在某个实例下发起重启类任务(包括配置变更、版本升级、开启ACL、实例升配)后,您可以在 云消息队列 Kafka 控制台查看重启类任务的执行记录,帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件 创建并部署 云消息队列 Kafka ...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力,云消息队列 Kafka 提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标,进而快速了解业务的运行状态。前提条件 开通ARMS Prometheus监控服务 ...

是否支持Compact的日志清理策略?

开源版本为2.2.0或以上的 云消息队列 Kafka 实例支持Compact的日志清理策略。开源版本为2.2.0或以上的 云消息队列 Kafka 实例支持Compact的日志清理策略。如需升级实例的开源版本以支持Compact的日志清理策略,请参见 升级大版本。

开发参考

本文介绍 云消息队列 Kafka 的SDK和API及Terraform的支持情况,供您进行对应的开发操作。开发参考 API参考指南 SDK参考 Terraform

云消息队列 Kafka 接入阿里云Elasticsearch

消息队列 Kafka 云消息队列 Kafka 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。更...

查看任务执行记录

在某个实例下发起重启类任务(包括实例升降配、定时任务)后,您可以在 云消息队列 Kafka 控制台查看该实例的重启类任务的执行记录,获取任务的类型、开始执行时间、结束执行时间、状态等信息。前提条件 创建并部署 云消息队列 Kafka ...

作为Input接入

云消息队列 Kafka 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 实例。具体操作,请参见 VPC...

迁移上云

计费说明 云消息队列 Kafka 的迁移上云组件处于公测阶段,且独立于 云消息队列 Kafka 实例,因此不会在 云消息队列 Kafka 侧产生费用。同时,阿里云不承诺迁移的SLA,使用迁移上云所依赖的其他产品的SLA和费用说明请以对应产品为...

创建MNS Sink Connector

本文介绍如何在 云消息队列 Kafka 控制台创建消息流出任务,将 云消息队列 Kafka 的数据导出至 消息服务。前提条件 您已购买并部署 云消息队列 Kafka 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。您...

控制台看到的最近消费时间是什么意思?

消息发布到 云消息队列 Kafka 服务器的存储时间。控制台看到的 最近消费时间 是指消息发布到 云消息队列 Kafka 服务器的存储时间。如果消费没有堆积,那么这个时间接近发送时间。

创建RabbitMQ Sink Connector

本文介绍如何在 云消息队列 Kafka 控制台创建消息流出任务,将 云消息队列 Kafka 的数据导出至 云消息队列 RabbitMQ 版。前提条件 您已购买并部署 云消息队列 Kafka 实例,且实例处于服务中状态。具体步骤,请参见 步骤二:购买和...

续费操作

登录 云消息队列 Kafka 控制台,在 概览 页面的 资源分布 区域,选择地域。在 实例列表 页面,单击目标实例名称。在 实例详情 页面,单击 概览 区域右上角的 续费。在 续费 面板,选择购买时长,并选中 消息队列 Kafka(包年包月)服务...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
新人特惠 爆款特惠 最新活动 免费试用