aliyun消息队列 Kafka有试用的么-aliyun消息队列 Kafka有试用的么文档介绍内容-阿里云

操作指南

您可以在 云消息队列 Kafka 版控制台创建实例、进行消息收发。云消息队列 Kafka 版 V3系列Serverless实例管理 V2系列实例管理 Topic Group Connector生态集成迁移权限管理云消息队列 Confluent 版集群资源规格评估实例管理权限管理 ...

RAM跨云账号授权

背景信息企业A开通了 云消息队列 Kafka 版，该企业需要企业B代为操作 云消息队列 Kafka 版的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为 云消息队列 Kafka 版所有者。企业A希望可以授权企业B来...

使用Spring Cloud框架收发消息

本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版并收发消息。前提条件安装1.8或以上版本JDK。安装2.5或以上版本Maven。下载 kafka-spring-stream-demo，并将其上传在准备好的Linux操作系统。确保您的 云消息队列 Kafka 版 ...

迁移Topic上云

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

SSL证书算法升级说明

前提条件您已购买 云消息队列 Kafka 版公网实例，且实例处于服务中状态。背景信息您的实例开启公网时，会启动SSL相关的端口，在 云消息队列 Kafka 版控制台的配置信息页面可以看到SSL证书算法位数。请根据您的安全需求按需选择...

搭配云HBase和Spark构建一体化数据处理平台

实时计算：通过X-Pack Spark Streaming实时地消费 云消息队列 Kafka 版的消息，写入到云HBase中对外提供在线查询。实时存储与检索：云HBase融合Solr以及Phoenix SQL层能够提供海量的实时存储，以及在线查询检索。批处理、数仓及算法：在线...

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

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

API概览

本产品（云消息队列 Kafka 版/2019-09-16）的OpenAPI采用 RPC 签名风格，签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用...

作为Input接入

云消息队列 Kafka 版可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版消费消息。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版实例。具体操作，请参见 ...

什么是云消息队列 Kafka 版？

三分钟了解阿里云 云消息队列 Kafka 版。

功能特性

Kafka商业模式功能集功能功能描述参考文档 Serverless版本升降配管理在云消息队列 Kafka 版控制台完成实例升配或降配，配置项包括规格类型、实例类型、发送能力预留和订阅能力预留等。升级实例配置降低实例配置弹性策略 V3系列...

如何处理不活跃的Topic

上述2个关键指标可通过下列2种方式获取：通过管理控制台查看Topic信息登录 云消息队列 Kafka 版控制台。在顶部菜单栏，选择地域。在左侧导航栏，单击实例列表，单击需要查询的Kafka实例名称。在实例详情页面，单击左侧导航栏中的 Topic...

迁移数据上云

云消息队列 Kafka 版集群的SSL接入点（可在 云消息队列 Kafka 版控制台获取）bootstrap.servers=XXX.XXX.XXX.XXX:9093#数据压缩方式 compression.type=none#truststore（使用步骤1下载的文件）ssl.truststore.location=kafka.client....

SourceKafkaParameters

名称类型描述示例值 object EventBridge 消息队列 Kafka 版的自定义事件源参数 ConsumerGroup string 订阅该 Topic 的消费者所对应的 Group ID。DEFAULT_GROUP InstanceId string 消息队列 Kafka 版的实例的 ID。r-8vb64581862c*Network...

是否支持延迟消息？

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

自由使用Group

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

将云消息队列 Kafka 版的数据迁移至MaxCompute

本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...

查看消费明细

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

为什么不能登录部署云消息队列 Kafka 版的机器？

云消息队列 Kafka 版提供全托管免运维服务，您无需登录机器。云消息队列 Kafka 版是全托管的，由 云消息队列 Kafka 版专业团队进行运维保障，您无需登录机器。集群的一些基础信息会通过监控告警进行透传。

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

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

云上迁移Topic

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

RAM主子账号授权

背景信息企业A开通了 云消息队列 Kafka 版服务，该企业需要员工操作 云消息队列 Kafka 版服务所涉及的资源，例如实例、Topic、Consumer Group。由于每个员工的工作职责不一样，需要的权限也不一样。企业A的需求如下：出于安全或信任的...

Topic的存储有哪些类型？

云存储和Local存储。云消息队列 Kafka 版实例支持云存储和Local存储。详情请参见存储引擎对比。

开源对比

项目 云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式 云消息队列 Kafka 版控制台 云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建 云消息队列 Kafka 版默认通过阿里云控制...

开服地域

本文介绍 云消息队列 Kafka 版的服务地域和各地域功能（Connector、数据处理和消息检索等）开通情况。下表中的表示该功能已在该地域支持，表示暂不支持指定地域。公共云地域名称 RegionId Connector（公测中）数据处理（公测中）消息...

迁移消费者程序

本文介绍如何将自建Kafka集群上的消费者程序平滑地迁移到 云消息队列 Kafka 版。背景信息 云消息队列 Kafka 版控制台提供迁移实例功能，您可以使用该功能将自建Kafka集群或其他云Kafka集群的元数据（Topic和Group配置信息）和消息数据同步...

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

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

在Knative上实现Kafka消息推送

前提条件部署Knative 购买并部署 云消息队列 Kafka 版实例重要 云消息队列 Kafka 版实例和Knative必须处于同一VPC内。云消息队列 Kafka 版实例的版本必须为2.0.0或以上。创建Topic 创建 Group 背景信息 Knative是一款基于Kubernetes的...

为什么消息已经过期还未被删除？

问题现象您发送的消息在服务端...磁盘容量充足，使用率低于75%，云消息队列 Kafka 版设置的集中清理消息的时间还未到，消息不会被删除。说明磁盘使用率低于75%时，在每天凌晨4点，云消息队列 Kafka 版集中删除超过消息保留时长的消息。

消息队列Kafka版系统权限策略参考

本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）...

查看接入点

如需使用SDK接入 云消息队列 Kafka 版收发消息，您需要根据实例的网络环境类型来配置接入点。本文介绍如何在 云消息队列 Kafka 版控制台查看接入点。背景信息 云消息队列 Kafka 版提供以下类型的接入点：默认接入点：适用于在VPC环境...

访问链接与端口

开启公网登录 云消息队列 Kafka 版控制台，在左侧导航栏，单击实例列表。在顶部菜单栏，选择地域，在实例列表页面单击目标实例名称。在左侧导航栏，单击访问链接与端口。在目标服务右侧，打开开启开关，为服务开启公网。说明开启...

云消息队列 Kafka 版支持被审计的事件说明

云消息队列 Kafka 版已与操作审计服务集成，您可以在操作审计中查询操作 云消息队列 Kafka 版产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。事件...

欠费说明

欠费影响如果您购买的为包年包月实例，实例到期后，您账户下的 云消息队列 Kafka 版服务会切换为已过期状态，即您将不能再继续使用 云消息队列 Kafka 版服务。如果您购买的为按量计费实例或弹性按量计费实例，当您的账户余额不足以...

查看实例风险

云消息队列 Kafka 版实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案检测项说明若检测出实例存在风险，请参考控制台上提示的...

为什么Group管理页面的Group变多了？

问题现象在 云消息队列 Kafka 版控制台的 Group 管理页面查看您Kafka集群上所有存在的Group时，显示的Group数量多于您手动创建的数量。可能原因若Group的自动创建栏为否，说明此Group创建于 云消息队列 Kafka 版控制台的 Group ...

实践教程

针对各种业务需求，云消息队列 Kafka 版提供相关的实践教程，您可以根据本文查看适合您业务的实践教程文档。实践教程最佳实践生态对接

UpdateInstanceConfig-修改实例的配置

操作访问级别资源类型条件关键字关联操作 alikafka:UpdateInstance Write 全部资源*无无请求参数名称类型必填描述示例值 Config string 是需要更新的云消息队列 Kafka 版的配置。配置信息必须是一个合法的 JSON 字符串。{...

实例运行健康自检指南

java-jar KafkaChecker.jar telnet-s 接入点例如：客户端通过专有网络VPC默认接入点接入 云消息队列 Kafka 版，则执行 java-jar KafkaChecker.jar telnet-s alikafka-pre-cn-zv*-1-vpc.alikafka.aliyuncs.com:9092,alikafka-pre-cn-zv*-2-...

Filebeat发送失败问题

问题现象在 云消息队列 Kafka 版控制台的 Topic 管理页面，您已成功创建Topic，但使用Filebeat向该Topic发送消息却出现 Request was for a topic or partition that does not exist on this broker.的错误提示。可能原因 Filebeat向...

aliyun消息队列 Kafka有试用的么

新品推荐