服务关联角色

本文介绍消息队列Kafka版服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息 服务关联角色是某个云服务在某些情况下,为了完成自身的某个功能,需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台首次使用...

VPC接入

如果仅需要在VPC网络接入消息队列Kafka版,您可以购买并部署VPC实例。前提条件 已授予消息队列Kafka版访问其他云服务资源的权限。具体信息,请参见步骤一:获取访问授权。已搭建VPC网络。具体操作,请参见使用专有网络。步骤一:购买实例 ...

如何监控开源Apache Kafka

本文为您介绍监控开源Apache Kafka的解决方案。如果您需要监控开源Apache Kafka,请参见以下解决方案:How to Monitor Kafka Monitoring Kafka performance metrics

RAM跨云账号授权

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

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

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

SASL接入点PLAIN机制收发消息

本文介绍如何在VPC环境下通过SASL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 您已安装.NET。更多信息,请参见安装.NET。安装C#依赖库 执行以下命令安装C#依赖库。dotnet add package-v 1.5.2 Confluent.Kafka 发送消息 ...

SASL接入点SCRAM机制收发消息

本文介绍如何在VPC环境下通过SASL接入点接入消息队列Kafka版并使用SCRAM机制收发消息。前提条件 您已安装.NET。更多信息,请参见安装.NET。安装C#依赖库 执行以下命令安装C#依赖库。dotnet add package-v 1.5.2 Confluent.Kafka 发送消息 ...

接入点对比

消息队列Kafka使用SCRAM-SHA-256加密算法实现身份校验,比PLAIN机制安全性更高,同样支持不重启实例的情况下动态增加SASL用户。SSL(Secure Sockets Layer):以保障数据传输过程的安全,采用数据加密技术,防止数据在网络传输过程中被...

SSL接入点PLAIN机制收发消息

本文介绍如何在公网环境下通过SSL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 您已安装Go。更多信息,请参见安装Go。说明 该kafka-confluent-go-demo不支持Windows系统。准备配置 访问aliware-kafka-demos,单击图标,...

默认接入点收发消息

本文介绍如何在VPC环境下通过默认接入点接入消息队列Kafka版并收发消息。前提条件 您已安装Go。更多信息,请参见安装Go。说明 该kafka-confluent-go-demo不支持Windows系统。准备配置 访问aliware-kafka-demos,单击图标,然后在下拉框选择...

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

概述 不在同一可用区内的ECS实例可通过非公网的方式访问消息队列Kafka版实例,详情请查看以下内容。详细信息 以非公网的方式访问消息队列Kafka版实例时,必须满足以下两个条件:ECS实例与消息队列Kafka版实例在同一VPC网络实例内。说明:...

SSL接入点PLAIN机制收发消息

本文介绍如何在公网环境下使用C#SDK通过SSL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 您已安装.NET。更多信息,请参见安装.NET。安装C#依赖库 执行以下命令安装C#依赖库。dotnet add package-v 1.5.2 Confluent.Kafka ...

SASL接入点PLAIN机制收发消息

本文介绍如何在VPC环境下通过SASL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 您已安装Go。更多信息,请参见安装Go。说明 kafka-confluent-go-demo不支持Windows系统。准备配置 访问aliware-kafka-demos,单击图标,然后...

SASL接入点SCRAM机制收发消息

本文介绍如何在VPC环境下通过SASL接入点接入消息队列Kafka版并使用SCRAM机制收发消息。前提条件 您已安装Go。更多信息,请参见安装Go。说明 该kafka-confluent-go-demo不支持Windows系统。准备配置 访问aliware-kafka-demos,单击图标,...

默认接入点收发消息

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

默认接入点收发消息

本文介绍如何在VPC环境下使用Node.js SDK通过默认接入点接入消息队列Kafka版并收发消息。前提条件 安装GCC 安装Node.js 注意 Node.js版本必须大于等于4.0.0。安装OpenSSL 安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/...

默认接入点收发消息

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

SASL接入点SCRAM机制收发消息

本文介绍Java SDK如何在VPC环境下通过SASL接入点接入消息队列Kafka版并使用SCRAM机制收发消息。前提条件 安装1.8或以上版本JDK 安装2.5或以上版本Maven SASL用户授权 安装Java依赖库 在pom.xml中添加以下依赖。lt;dependency>lt;groupId...

默认接入点收发消息

本文介绍如何在VPC环境下使用Java SDK接入消息队列Kafka版的默认接入点并收发消息。前提条件 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在pom.xml中添加以下依赖。lt;dependency>lt;groupId>org.apache.kafka<...

发布者最佳实践

本文介绍消息队列Kafka版发布者的最佳实践,帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端,其基本概念与思想是相通的,但实现细节可能存在差异。发送消息 发送消息的示例代码如下:Future<...

升级实例版本

本文说明如何升级消息队列Kafka版实例的版本。前提条件 消息队列Kafka版实例的状态为服务中。背景信息 升级大版本 升级大版本是指跨版本升级,例如将消息队列Kafka版实例的版本从0.10.x版本升级至2.x版本。说明 消息队列Kafka版实例支持0....

SASL接入点PLAIN机制收发消息

本文介绍Java客户端如何在VPC环境下通过SASL接入点接入消息队列Kafka版并使用PLAIN机制收发消息。前提条件 安装1.8或以上版本JDK 安装2.5或以上版本Maven SASL用户授权 安装Java依赖库 在pom.xml中添加以下依赖。lt;dependency>lt;...

订阅者最佳实践

更多信息,请参见使用消息队列Kafka版时消费客户端频繁出现Rebalance。分区个数 分区个数主要影响的是消费者的并发数量。对于同一个Group内的消费者来说,一个分区最多只能被一个消费者消费。因此,消费实例的个数不要大于分区的数量,否则...

使用消息队列Kafka版时出现消息堆积

概述 使用消息队列Kafka版时,可能会发现Group中出现消息堆积。该情况是否属于正常情况,以及如何处理,请参见以下内容。详细信息 客户端消费流程 了解客户端消费流程,有助于理解消息是否堆积。一般情况下,客户端消费流程大致如下:步骤1...

如何快速测试消息队列Kafka版服务端是否正常?

在创建并部署消息队列Kafka版实例后,您可以使用消息队列Kafka版控制台直接发送消息,快速测试服务端是否正常。前提条件 您已创建并部署消息队列Kafka版实例,且实例处于服务中状态。操作流程 快速测试消息队列Kafka版服务端的流程如下:...

消息队列Kafka版何时删除旧消息

为避免因磁盘容量不足而导致机器宕机,进而影响服务可用性,消息队列Kafka版对磁盘使用率进行了动态控制。磁盘使用率<75%:每天凌晨4点集中删除超过消息保留时长的消息。磁盘使用率介于[75%,85%)区间:定期删除超过消息保留时长的消息,...

SSL接入点PLAIN机制收发消息

本文介绍如何在公网环境下使用Java SDK接入消息队列Kafka版的SSL接入点并使用PLAIN机制收发消息。前提条件 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在pom.xml中添加以下依赖。lt;dependency>lt;groupId>org....

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

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

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

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

公网+VPC接入

如果需要同时在VPC网络和公网接入消息队列Kafka版,您需要购买并部署公网/VPC实例。前提条件 已授予消息队列Kafka版访问其他云服务资源的权限。具体信息,请参见步骤一:获取访问授权。已搭建VPC网络。具体操作,请参见使用专有网络。步骤...

默认接入点收发消息

本文以Java SDK为例介绍如何在VPC环境下使用SDK接入消息队列Kafka版的默认接入点并收发消息。前提条件 步骤三:创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在pom.xml中添加以下依赖。lt;dependency>lt;...

创建DLA Sink Connector

默认使用消息队列Kafka版的Topic名称作为表名,且把除去字母及数字的字符替换为下划线(_)。例如Topic名称为dla-test,表名默认变更为dla_test。dla_test 在使用必读:创建尚未完成,请在 DLA 控制台完成配置!对话框,认真阅读提示信息,...

SSL接入点PLAIN机制收发消息

本文以Java SDK为例介绍如何在公网环境下使用SDK接入消息队列Kafka版的SSL接入点并使用PLAIN机制收发消息。前提条件 步骤三:创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在pom.xml中添加以下依赖。lt;...

查看消费明细

如果您对消息队列Kafka版服务的消费情况产生疑问,可以查看消费明细。查看费用账单 登录消息队列Kafka版控制台。在页面右上角,选择费用>用户中心。在左侧导航栏,选择费用账单>费用账单页面,查看您的消费信息。在账单总览页签,...

SSL接入点PLAIN机制收发消息

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

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

六分钟上手消息队列Kafka版。文档教程 快速入门$icmsDocProps={'productMethod':'created','language':'zh-CN',};

应急预案:专有云V3环境中Kafka磁盘满导致消息写入...

1.概述 本文主要介绍在专有云V3环境中,Kafka磁盘满导致消息写入失败的处理方法。1.1.适用范围 专有云V3,消息队列Kafka 说明:适用于企业版和敏捷PaaS,且专有云版本为V3.13及之后版本。1.2.用户告知 适用平台:x86 授权级别:L2(二线...

查询消息

能否查询到消息,与消息队列Kafka版的消息清除策略相关:磁盘使用率低于85%,每天凌晨4点集中删除超过消息保留时间的消息。磁盘使用率达到85%,立即清除超过消息保留时间的消息。磁盘使用率达到90%,无论消息是否超过消息保留时间,按服务...

升级实例配置

本文介绍如何消息队列Kafka版控制台完成实例升配,升级的配置项包括规格类型、流量规格、磁盘容量及Topic规格等。应用场景 消息队列Kafka版实例的磁盘使用率偏高,即将影响正常业务进行。消息队列Kafka版实例的流量规格持续超过已购买的...

是否支持压缩消息

消息队列Kafka版服务端支持收发压缩消息。如需使用压缩消息,您需要在消息队列Kafka版的客户端进行设置。在消息队列Kafka版客户端进行消息压缩的说明如下:压缩格式:支持Snappy、LZ4、GZIP等压缩格式。其中,GZIP对CPU的消耗较高,因此不...
< 1 2 3 4 ... 200 >
跳转至: GO

新品推荐

你可能感兴趣

热门推荐

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