分布队列双重总线未响应-分布队列双重总线未响应文档介绍内容-阿里云

路由到云消息队列 Kafka 版

本文介绍如何在事件总线EventBridge 控制台添加云消息队列 Kafka 版作为事件流中的服务类型。前提条件开通事件总线EventBridge并授权。您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见购买和部署...

产品优势

云消息队列 Kafka 版 100%兼容开源，支持0.10.x~2.6.x的开源版本，无需代码改造无缝迁移上云，体验全托管、免运维的分布式消息队列服务。开箱即用云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100...

2020年

本文介绍事件总线EventBridge 2020年产品功能动态和文档情况，帮助您了解事件总线EventBridge 的发布动态。2020年12月功能名称功能描述发布时间相关文档事件源新增事件源资源编排。2020-12-23 产品功能事件源概述资源编排事件 ...

领域模型概述

产品定位云消息队列 RocketMQ 版是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文通信方式介绍和消息传输模型介绍。云消息队列 RocketMQ 版产品具备异步...

应用场景

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

接口和参数说明

本文介绍云消息队列 MQTT 版云端Java SDK提供的接口和相关的参数说明。使用说明公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...

常见问题

本文汇总了使用云消息队列 Kafka 版实例时的常见问题。计费问题为什么购买了按量付费实例后不使用也要收费？为什么按流量峰值收费？按流量峰值收费的依据是什么？为什么额外增加分区要收费？我使用的Connector组件如何计费？客户端报错 ...

消息队列RabbitMQ版推送事件到函数计算

前提条件您已完成以下操作：事件总线EventBridge 开通事件总线EventBridge并授权创建自定义总线函数计算创建服务创建函数创建日志项目和日志仓库配置SLS触发器收集导入日志云消息队列 RabbitMQ 版创建实例创建Vhost 创建...

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

部署架构图选用的产品云消息队列 Kafka 版云消息队列 Kafka 版是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...

基本概念

本文主要对云消息队列 RocketMQ 版涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用云消息队列 RocketMQ 版。Topic 消息主题，一级消息类型，通过Topic对消息进行分类。更多信息，请参见 Topic与Tag最佳实践。消息...

消息队列RocketMQ版推送事件到函数计算

前提条件您已完成以下操作：事件总线EventBridge 开通事件总线EventBridge并授权创建自定义总线函数计算创建服务创建函数创建日志项目和日志仓库配置SLS触发器收集导入日志消息队列RocketMQ版开通消息队列服务并授权创建实例、...

消费重试

消费者出现异常，云消息队列 RocketMQ 版会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景云消息队列 RocketMQ 版的消费重试主要解决的是业务处理逻辑失败导致的...

生产者负载均衡

生产者发送消息到云消息队列 RocketMQ 版服务端时，云消息队列 RocketMQ 版将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍云消息队列 RocketMQ 版生产者的负载均衡策略。背景信息了解...

按量计费转包年包月

前提条件您已购买并部署云消息队列 Kafka 版实例，且实例运行状态处于服务中或未部署。具体操作，请参见步骤二：购买和部署实例。注意事项按量计费转包年包月的过程中，实例始终处于服务中状态，不会因为实例重启而导致服务短暂不...

新功能发布记录

本文介绍云消息队列 Kafka 版的产品功能动态及对应的文档。2024-04-15 功能名称功能描述功能类型相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...

延时消息

如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用云消息队列 RabbitMQ 版的延时消息。云消息队列 RabbitMQ 版原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息延时消息是指在指定时间段之后才被消费者消费...

基于事件流实现RabbitMQ消息路由

本文介绍如何应用事件总线EventBridge 的事件流功能实现云消息队列 RabbitMQ 版的消息路由。前提条件您已开通事件总线EventBridge并授权。您已购买并部署云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见 ...

云监控

实例公网写入带宽 bit/s 实例公网读取带宽 bit/s Topic Topic消息生产流量 Bytes/s Topic消息消费流量 Bytes/s Group Group未消费消息总数个计费说明使用云监控功能云消息队列 Kafka 版不收取费用。前提条件创建服务关联角色角色...

JMS概述

云消息队列 RabbitMQ 版提供JMS库供JMS客户端接入云消息队列 RabbitMQ 版。本文介绍云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...

常见问题

本文介绍与事件总线EventBridge 相关的基本问题。什么是事件总线EventBridge？阿里云事件总线EventBridge 是阿里云自研全托管的无服务器事件驱动服务总线，具备高扩展性、高可靠性，支持事件查询、事件轨迹追踪、事件跨账号传输等一系列...

消息重试

云消息队列 RocketMQ 版支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版会根据消息重试机制重新投递消息。本文介绍云消息队列 RocketMQ 版分别在HTTP协议和TCP协议下的消息重试策略。注意事项一条...

作为Output接入

云消息队列 Kafka 版可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向云消息队列 Kafka 版发送消息。前提条件购买并部署云消息队列 Kafka 版实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...

消息检索

当云消息队列 Kafka 版控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用云消息队列 Kafka 版消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...

查看任务执行记录

操作步骤登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。在实例列表页面，单击目标实例名称。在实例详情页面，单击任务执行记录页签。在任务执行记录页签下方显示重启类任务的执行记录。参数描述 ...

升级实例配置

本文介绍如何在云消息队列 Kafka 版控制台完成实例升配，升级的配置项包括规格类型、流量规格、磁盘容量及分区规格等。前提条件实例处于服务中或未部署状态。实例中没有进行中的Topic引流任务。注意事项升级实例配置会引发集群逐台...

消息轨迹

在分布式应用中，云消息队列 RocketMQ 版作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版定义的轨迹参数...

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

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

查看实例风险

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

作为Output接入

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

查看实例风险

消费流量 Group与Topic的订阅关系服务端小版本升级消费位点提交频率存在Rebalance的Group 消费客户端主动离开队列使用Sarama Go客户端操作步骤登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。...

VPC接入

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

降低实例配置

如果您的云消息队列 Kafka 版实例的公网流量消耗远小于购买的公网流量配置，或者分区的使用量远小于购买的分区数量，您可以降低公网流量和分区数量配置，从而节约成本。本文介绍如何在云消息队列 Kafka 版控制台降低实例的公网流量、...

消息查询

在概览页面的资源分布区域，选择地域。在实例列表页面，单击目标实例名称。在左侧导航栏，单击消息查询。在消息查询页面的查询方式列表中，选择按位点查询。在 Topic 列表中，选择消息所属Topic名称；在分区列表中，选择消息...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。交互流程事务消息交互流程如下图所示。更多信息，请参见事务消息。前提条件您已完成以下操作：下载C...

创建SLS Sink Connector

本文介绍如何创建使用SLS Sink Connector，您可通过SLS Sink Connector将数据从云消息队列 Kafka 版实例的数据源Topic导出至日志服务SLS。前提条件详细步骤，请参见创建前提。步骤一：创建目标服务资源创建日志项目（Project）。详细...

公网和VPC接入

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

迁移自建Kafka集群至新实例

本文介绍如何在云消息队列 Kafka 版控制台创建并启动迁移任务。前提条件下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置，推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件，但自动安装...

弹性策略

增加定时任务登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。在实例列表页面，单击目标实例名称。在实例列表页面，单击弹性策略页签。在定时策略区域，单击增加定时任务，在新增定时策略面板，...

管理Kafka自定义连接器

登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。在左侧导航栏，选择 Connector生态集成>消息流入（Source）。在消息流入（Source）页面，单击创建任务。在消息流入创建面板中，完成以下配置，单击确定。...

分布队列双重总线未响应

新品推荐