Node.js SDK概述

Node.js客户端可以通过消息队列Kafka版提供的多种接入点接入并收发消息消息队列Kafka版提供以下接入点。项目 默认接入点 SSL接入点 SASL接入点 网络 VPC 公网 VPC 协议 PLAINTEXT SASL_SSL SASL_PLAINTEXT 端口 9092 9093 9094 SASL机制 ...

Java SDK概述

Java客户端可以通过消息队列Kafka版提供的多种接入点接入并收发消息消息队列Kafka版提供以下接入点。项目 默认接入点 SSL接入点 SASL接入点 网络 VPC 公网 VPC 协议 PLAINTEXT SASL_SSL SASL_PLAINTEXT 端口 9092 9093 9094 SASL机制 不...

正式商用公告

本章节介绍消息队列Kafka版的正式商用公告细则。正式商用细则 消息队列Kafka版的正式商用细则如下:为提高服务质量和用户体验,消息队列Kafka版全部以商用实例方式提供服务。实例的基本规格和定价信息请参见计费说明。如果您有共享服务需求...

C++ SDK概述

C++客户端可以通过消息队列Kafka版提供的多种接入点接入并收发消息消息队列Kafka版提供以下接入点。项目 默认接入点 SSL接入点 SASL接入点 网络 VPC 公网 VPC 协议 PLAINTEXT SASL_SSL SASL_PLAINTEXT 端口 9092 9093 9094 SASL机制 不...

默认接入点收发消息

本文介绍如何在VPC环境下使用Ruby SDK通过默认接入点接入消息队列Kafka版并收发消息。前提条件 您已安装Ruby。更多信息,请参见安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 发送消息 创建发送...

创建MaxCompute Sink Connector

本文说明如何创建MaxCompute Sink Connector将数据从消息队列Kafka版实例的数据源Topic导出至MaxCompute的表。前提条件 在创建MaxCompute Sink Connector前,请确保您已完成以下操作:为消息队列Kafka版实例开启Connector。更多信息,请...

概述

操作步骤 具体操作步骤如下:步骤一:获取访问授权 步骤二:购买和部署实例 VPC接入 公网+VPC接入 步骤三:创建资源 步骤四:使用SDK收发消息 默认接入点收发消息 SSL接入点PLAIN机制收发消息 视频教程 如何快速使用消息队列Kafka版的Java ...

Ruby SDK概述

Ruby客户端可以通过消息队列Kafka版提供的多种接入点接入并收发消息消息队列Kafka版提供以下接入点。项目 默认接入点 SSL接入点 SASL接入点 网络 VPC 公网 VPC 协议 PLAINTEXT SASL_SSL SASL_PLAINTEXT 端口 9092 9093 9094 SASL机制 不...

开启Connector

本文说明如何消息队列Kafka版实例开启Connector。前提条件 您已购买并部署消息队列Kafka版实例,且该实例必须满足以下条件:项目 说明 状态 服务中 版本 消息队列Kafka版实例的版本必须满足以下任意一种要求:大版本为0.10.2,且小版本为...

SSL接入点PLAIN机制收发消息

本文介绍如何在公网环境下使用Ruby SDK通过SSL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 您已安装Ruby。更多信息,请参见安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备...

应用场景

本文介绍消息队列Kafka版的典型应用场景,包括网站活动跟踪、日志聚合、流计算处理、数据中转枢纽。网站活动跟踪 成功的网站运营需要对站点的用户行为进行分析。通过消息队列Kafka版的发布/订阅模型,您可以实时收集网站活动数据(例如注册...

Python SDK概述

Python客户端可以通过消息队列Kafka版提供的多种接入点接入并收发消息消息队列Kafka版提供以下接入点。项目 默认接入点 SSL接入点 SASL接入点 网络 VPC 公网 VPC 协议 PLAINTEXT SASL_SSL SASL_PLAINTEXT 端口 9092 9093 9094 SASL机制 ...

作为Input接入

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

作为Output接入

本文说明如何在公网环境下通过Logstash向消息队列Kafka版发送消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署消息队列Kafka版实例。具体操作,请参见公网+VPC接入。下载并安装Logstash。具体操作,请参见Download ...

作为Input接入

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

欠费说明

欠费影响 如果您购买的服务已到期,您账户下的消息队列Kafka版服务会立即停机,即您将不能再继续使用消息队列Kafka版服务。如果停机后168小时依然欠费,消息队列Kafka版实例将会释放,实例释放后数据不可恢复,即您不能再使用消息队列Kafka...

作为Output接入

本文说明如何在VPC环境下通过Logstash向消息队列Kafka版发送消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署消息队列Kafka版实例。具体操作,请参见VPC接入。下载并安装Logstash。具体操作,请参见Download Logstash。...

作为Input接入

本文说明如何在VPC环境下通过Logstash从消息队列Kafka版消费消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署消息队列Kafka版实例。具体操作,请参见VPC接入。下载并安装Logstash。具体操作,请参见Download Logstash。...

欠费说明

如果停机后168小时依然欠费,消息队列Kafka版实例将会释放,实例释放后数据不可恢复,即您不能再使用消息队列Kafka版服务。为避免服务停止影响您的业务,建议您在欠费168小时内充值。充值具体操作,请参见如何充值。欠费提醒 实例到期欠费...

作为Output接入

本文说明如何在VPC环境下通过Filebeat向消息队列Kafka版发送消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署消息队列Kafka版实例。更多信息,请参见VPC接入。下载并安装Filebeat。更多信息,请参见Download Filebeat。...

使用Kafka Connect将MySQL数据同步至消息队列Kafka

本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至消息队列Kafka版。背景信息 Kafka Connect主要用于将数据流输入和输出消息队列Kafka版。Kafka Connect主要通过各种Source Connector的实现,将数据从第三方系统输入...

作为Input接入

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

SSL接入点PLAIN机制收发消息

本文介绍在公网环境下如何使用Python SDK通过SSL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 安装Python 说明 Python版本为2.7、3.4、3.5、3.6或3.7。安装pip 安装Python依赖库 执行以下命令安装Python依赖库。pip ...

SSL接入点PLAIN机制收发消息

本文介绍如何在公网环境下使用C++ SDK通过SSL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 您已安装GCC。更多信息,请参见安装GCC。安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/yum.repos.d/...

自动创建Group

背景信息 自动创建Group是指当消息队列Kafka版实例发送请求以获取不存在的Group元数据时,例如使用不存在的Group订阅消息消息队列Kafka版实例会自动创建Group。注意事项 在生产环境,长期开启自动创建Group的功能,可能会因为客户端使用...

作为Output接入

本文说明如何在公网环境下通过Filebeat向消息队列Kafka版发送消息。前提条件 在开始本教程前,请确保您已完成以下操作:购买并部署消息队列Kafka版实例。具体操作,请参见公网+VPC接入。下载并安装Filebeat。具体操作,请参见Download ...

计费概述

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

云上迁移Topic

本文介绍如何使用消息队列Kafka版提供的迁移工具将某个消息队列Kafka版实例的Topic迁移到另一个消息队列Kafka版实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具JAR文件 注意 迁移不会删除源消息队列Kafka版实例的Topic,只是在...

默认接入点收发消息

本文介绍如何在VPC环境下使用C++ SDK通过默认接入点接入消息队列Kafka版并收发消息。前提条件 您已安装GCC。更多信息,请参见安装GCC。安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/yum.repos.d/创建yum源配置...

使用限制

消息队列Kafka版对某些具体指标进行了约束和规范,您在使用消息队列Kafka版时注意不要超过相应的限制值,以免程序出现异常。具体的限制项和限制值,请参见下表。限制项 限制值 说明 限制Topic总数(分区总数)支持 消息队列Kafka版的存储和...

客户端首次接入消息队列Kafka版时出现异常的排查方法

概述 本文主要介绍客户端首次接入消息队列Kafka版时,出现异常的排查方法。详细信息 客户端首次接入消息队列Kafka版时如果出现异常,您可以通过下列三个方面进行排查:网络连通问题:通常有如下几种可能性导致网络不通,客户端无法连接消息...

RAM权限策略

消息队列Kafka版支持以下两种类型的权限策略:系统权限策略:统一由阿里云创建,您只能使用不能修改,策略的版本更新由阿里云维护,适用于粗粒度地控制RAM用户权限。自定义权限策略:您可以自主创建、更新和删除,策略的版本更新由您自己...

删除Connector

消息队列Kafka版限制了每个实例的Connector数量。如果您不再需要某个Connector,您可以在消息队列Kafka版控制台删除该Connector。前提条件 您已创建以下任意一种Connector:创建FC Sink Connector 创建MaxCompute Sink Connector 创建OSS ...

基于Flink的资讯场景实时数仓

本文介绍如何针对资讯聚合类业务场景搭建基于消息队列Kafka版和实时计算Flink的实时数仓。场景描述 本文首先介绍什么是实时数仓以及相关技术架构,接着介绍资讯聚合类业务的典型场景及其业务目标,并据此设计了相应的技术架构。然后介绍...

获取SDK

本文介绍如何获取消息队列Kafka版的SDK。消息队列Kafka版支持以下语言的SDK。语言 SDK Java Aliyun Java SDK Alikafka Go Aliyun Go SDK Alikafka PHP Aliyun PHP SDK Alikafka

配置白名单

您可以编辑访问消息队列Kafka版的白名单,配置在白名单中的IP地址与端口才允许访问消息队列Kafka版实例。前提条件 您已购买消息队列Kafka版实例,且该实例处于服务中的状态。注意事项 白名单最多支持100条。增加白名单时,每一条白名单中...

创建FC Sink Connector

本文说明如何创建FC Sink Connector,您可以通过FC Sink Connector将数据从消息队列Kafka版实例的数据源Topic导出至函数计算的函数。前提条件 在创建FC Sink Connector前,请确保您已完成以下操作:为消息队列Kafka版实例开启Connector。更...

查看接入点

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

消息队列Kafka版控制台的报警项中状态列显示“数据...

问题描述 在消息队列Kafka版控制台的报警项中,状态列显示“数据不足”。问题原因 虽然配置了报警规则,但您的消息队列Kafka版...适用于 消息队列Kafka版 如果您的问题仍未解决,您可以在阿里云社区免费咨询,或提交工单联系阿里云技术支持。

消息队列Kafka版实例删除Group后仍然可以接收到消息

问题描述 使用消息队列Kafka版实例时,删除Group后仍然可以接收到消息。问题原因 历史版本的消息队列Kafka版实例在删除Group时,不会彻底清除路由信息,导致被删除的Group依然可以收到消息。解决方案 阿里云提醒您:如果您对实例或数据有...
< 1 2 3 4 ... 200 >
跳转至: GO

新品推荐

你可能感兴趣

热门推荐

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折