实例规格配置和管理
前提条件 您已购买 云消息队列 Kafka 版 V3系列Serverless实例，且实例处于 服务中 状态。规格配置说明 配置项 含义 变更方式 流量规格 发送能力预留 消息生产预留规格，生产弹性上限为此数值的2倍，超出生产弹性上限的部分将会被限流。...
Ruby SDK收发消息
本文介绍如何使用Ruby SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 您已安装Ruby。更多信息，请参见 安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置 可选：下载SSL根...
升级实例版本
前提条件 云消息队列 Kafka 版 实例的状态为 服务中。背景信息 升级大版本 升级大版本是指跨版本升级，例如将 云消息队列 Kafka 版 实例的版本从0.10.x版本升级至2.x版本。重要 目前新部署实例仅支持2.x版本，存量0.10.x可正常使用。由于2....
重置消费位点
前提条件 已停止所有Consumer客户端（云消息队列 Kafka 版 不支持在线重置消费位点）。重要 在停止Consumer客户端后，需要经过 ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG 配置的时间（默认10000 ms），服务端才认为Consumer真正下线。背景...
消息查询
注意事项 查询到的每条消息在 云消息队列 Kafka 版 控制台上最多显示1 KB的内容，超过1 KB的部分将自动截断。如需查看完整的消息内容，请下载相应的消息，下载的消息最大为10 MB，如果超过10 MB，则只下载10 MB的内容。查询结果最多显示10...
续费操作
登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 概览 区域右上角的 续费。在 续费 面板，选择购买时长，并选中 消息队列 Kafka（包年包月）服务...
云消息队列 Kafka 版支持被审计的事件说明
云消息队列 Kafka 版 已与操作审计服务集成，您可以在操作审计中查询操作 云消息队列 Kafka 版 产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。事件...
新增分区时对应的Topic数量额度
可使用的Topic数量与总分区数强相关。例如，您已购买了分区数为50、流量规格为alikafka.hw.2xlarge、规格内赠送分区数为1000的实例，那么该...云消息队列 Kafka 版 Serverless实例不受此项限制。购买分区的操作步骤，请参见 升级实例配置。
创建FC Sink Connector
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已开通函数计算服务，具体操作，请参见 开通服务。开通事件总线EventBridge并授权。什么是函数计算？函数计算...
为什么消费位点过期了却仍未被删除？
问题现象 2.2.0及以上 云消息队列 Kafka 版 服务端版本，某Group下的消费位点已经超过了我设置的消费位点保留时间，但却未被删除，还可以在 云消息队列 Kafka 版 控制台 的订阅关系里看到对应的消费位点。说明 消费位点保留时长 是消费位点...
实例规格
本文说明 云消息队列 Kafka 版 支持的规格类型，以便您根据实际业务需求选择合适的实例规格。实例规格类型 云消息队列 Kafka 版 实例规格类型如下：项目 标准版（高写版）专业版（高写版）专业版（高读版）版本 支持部署2.x版本。如需升级...
迁移Group上云
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将自建Kafka集群的 Group 迁移到 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作：下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka 版 ...
用户管理
查看用户列表 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击左侧操作栏的 用户管理，查看所有用户列表。新增用户 在 用户管理 页面，单击 添加LDAP用户。在...
如何处理不活跃的Topic
上述2个关键指标可通过下列2种方式获取：通过管理控制台查看Topic信息 登录 云消息队列 Kafka 版 控制台。在顶部菜单栏，选择地域。在左侧导航栏，单击 实例列表，单击需要查询的Kafka实例名称。在实例详情页面，单击左侧导航栏中的 Topic...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
续费操作
登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击 概览 区域右上角的 续费。在 续费 面板，选择购买时长，并选中 消息队列 Kafka（包年包月）服务...
自动化创建Topic相关问题
本文汇总了 云消息队列 Kafka 版 关于自动创建Topic的相关问题。是否可以自动化创建Topic？可以，但不建议。云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不支持也不建议自动化创建Topic，主要原因如下：自动化创建...
自动创建Topic
前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且该实例必须满足以下条件：项目 说明 状态 服务中 版本 大版本为2.2.0或以上版本，小版本为最新版本。说明 您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面的 基础信息 区域查看...
为什么在控制台看不到消费者的客户端信息？
问题现象 在 云消息队列 Kafka 版 控制台 的 Topic 详情 页面的 订阅关系 页签，或者在 Group 详情 页面的 消费状态 页签，查看 消费详情 中的 客户端 信息为 n/a。可能原因 订阅该Topic分区的消费线程已经离线。Group触发Rebalance机制。...
如果已有实例按照Topic规格购买，如何计算Topic、...
云消息队列 Kafka 版 不再支持按照Topic规格购买实例。若您的已有实例是按照Topic规格购买 Topic说明如下：不同的流量规格对应不同的Topic或分区数量上限。在默认分区数的基础上，每增购1个Topic，对应增加16个分区。例如，您购买了Topic...
Python SDK收发消息
本文介绍如何使用Python SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 安装Python 说明 Python版本为2.7或3.X。安装pip 添加Python依赖库 执行以下命令安装依赖库。pip install confluent-kafka=1.9.2 重要 建议您安装...
如何选择实例规格？
云消息队列 Kafka 版 提供两种实例规格类型：标准版和专业版。您可以根据自建迁移情况选择实例规格。标准版 流量规格：集群流量的总量÷3（优化）磁盘大小：流量均值×存储时长×3（备份）分区数量：根据实际业务需求 说明 建议您在迁移...
内容分割
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
RBAC授权
在Control Center页面进行RBAC授权 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在 实例列表 页面，单击目标实例名称。在 实例详情 页面，单击右上角的 登录控制台。在集群Control Center页面，在右上角选择>Manage ...
内容映射
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
内容富化
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
PHP SDK收发消息
说明 如果实例未开启ACL，您可以在 云消息队列 Kafka 版 控制台 的 实例详情 页面的 配置信息 区域获取默认的 用户名 和 密码。如果实例已开启ACL，请确保要使用的SASL用户已被授予向 云消息队列 Kafka 版 实例收发消息的权限。具体操作，...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
动态路由
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 消息服务。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的修改。算子 算子...
变更消息配置
前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于服务中状态。操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面的 配置信息 区域，选择...
实例生命周期管理
本文介绍 云消息队列 Kafka 版 实例的控制台操作说明及生命周期管理过程，生命周期包括部署、释放、恢复实例等。控制台操作说明 云消息队列 Kafka 版 实例 操作 列的可操作性说明如下：操作不显示：不可操作。操作置灰：当前状态下不可操作...
开启幂等功能，发送消息报“Cluster authorization ...
说明 云消息队列 Kafka 版 客户端版本在V3.0及以上默认开启幂等功能（即 enable.idempotence=true）。为Cluster添加ACL相关权限，在控制台SASL权限管理页面添加对相应用户的Cluster资源类型的幂等写权限（IDEMPOTENT_WRITE）。更多信息，请...
Topic分区倾斜怎么办？
解决方案 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，然后在 实例列表 页面单击目标实例名称。在左侧导航栏，单击 Topic管理，然后单击目标Topic名称。在 Topic详情 页面的 配置信息 页签，...
Workers
默认Workers配置 云消息队列 Kafka 版 提供了对Confluent Kafka Connect进行半托管的一站式平台，提供如下默认配置：key.converter=org.apache.kafka.connect.storage.StringConverter key.converter.schemas.enable=true value.converter=...
RAM主子账号授权
背景信息 企业A开通了 云消息队列 Kafka 版 服务，该企业需要员工操作 云消息队列 Kafka 版 服务所涉及的资源，例如实例、Topic、Consumer Group。由于每个员工的工作职责不一样，需要的权限也不一样。企业A的需求如下：出于安全或信任的...
弹性策略
前提条件 创建并部署 云消息队列 Kafka 版 V3系列实例，且实例处于 服务中 状态。弹性能力 为应对生产环境中多阶梯的流量需求，云消息队列 Kafka 版 V3系列Serverless实例提供弹性伸缩流量规格的能力，您可以通过升配和降配修改发送、订阅...
升级Broker可能产生哪些影响？
升级Broker可能产生以下影响：升级过程中，会逐个重启 云消息队列 Kafka 版 集群中所有的Broker。在重启Broker的过程中服务不会中断，但是从每个Broker重启完成之后的5分钟内消费的分区消息可能会发生乱序。重启过程中已有的客户端连接可能...
为什么查询到的消息创建时间与设置的消息查询时间点...
问题现象 登录 云消息队列 Kafka 版 控制台，在 消息查询 页面，查询方式 选择 按时间点查询，时间点 设置需查询的时间点，查询到的 消息创建时间 与设置的查询时间点偏差很大，或者查询到的 消息创建时间 值为空值。可能原因 设置的查询...
为什么消费客户端频繁出现Rebalance？
可能是 云消息队列 Kafka 版 客户端版本过低或者Consumer没有独立线程维持心跳。问题现象 使用 云消息队列 Kafka 版 时，消费客户端频繁出现Rebalance。可能原因 可能导致故障的原因包括：v0.10.2之前版本的客户端：Consumer没有独立线程...
升降配管理
本文介绍如何在 云消息队列 Kafka 版 控制台完成实例升配或降配，配置项包括规格类型、实例类型、发送能力预留和订阅能力预留等。前提条件 实例处于 服务中 或 未部署 状态。升降配说明 为保障在预留规格生效时间内升配或者降配至预设容量...
- 产品推荐
- 这些文档可能帮助您