分布队列双重总线怎么重启-分布队列双重总线怎么重启文档介绍内容-阿里云

自定义事件源消息服务MNS

前提条件消息服务MNS 开通消息服务MNS并授权创建队列事件总线EventBridge 开通事件总线EventBridge并授权创建自定义总线操作步骤登录事件总线EventBridge控制台。在左侧导航栏，单击事件总线。在顶部菜单栏，选择地域。在事件总线...

队列（MessageQueue）

常见队列增加场景需要增加队列实现物理节点负载均衡云消息队列 RocketMQ 版每个主题的多个队列可以分布在不同的服务节点上，在集群水平扩容增加节点后，为了保证集群流量的负载均衡，建议在新的服务节点上新增队列，或将旧的队列迁移到...

功能与特性概述

云消息队列 RocketMQ 版的分布式特点和瞬变的网络条件，或者用户应用重启发布的情况下，可能导致消费者收到重复的消息。开发人员应将其应用程序设计为多次处理一条消息不会产生任何错误或不一致性。消息幂等最佳实践请参见消费幂等。消息...

应用场景

本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...

查看任务执行记录

在某个实例下发起重启类任务（包括配置变更、版本升级、开启ACL、实例升配）后，您可以在云消息队列 Kafka 版控制台查看重启类任务的执行记录，帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件创建并部署云消息队列 Kafka 版 ...

领域模型概述

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

基本概念

本文说明云消息队列 Kafka 版涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...

什么是云消息队列 RocketMQ 版？

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...

事务消息

云消息队列 RocketMQ 版提供的分布式事务消息适用于所有对数据最终一致性有强需求的场景。本文介绍云消息队列 RocketMQ 版事务消息的概念、优势、典型场景、交互流程、使用规则以及示例代码。概念介绍事务消息：云消息队列 RocketMQ 版...

升级多可用区

操作步骤登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。在实例列表页面，单击目标实例名称。在实例详情页面的配置信息区域，单击备用可用区右侧的编辑，设置对应的备用可用区和执行时间。在 ...

升级实例配置

操作步骤登录云消息队列 Kafka 版控制台，在概览页面的资源分布区域，选择地域。在实例列表页面，单击目标实例名称。在实例详情页面，单击概览区域右上角的升配。在实例升配风险说明对话框，阅读并确认实例升级风险说明，...

查看任务执行记录

在某个实例下发起重启类任务（包括实例升降配、定时任务）后，您可以在云消息队列 Kafka 版控制台查看该实例的重启类任务的执行记录，获取任务的类型、开始执行时间、结束执行时间、状态等信息。前提条件创建并部署云消息队列 Kafka 版...

按量计费转包年包月

注意事项按量计费转包年包月的过程中，实例始终处于服务中状态，不会因为实例重启而导致服务短暂不可用。按量计费转包年包月不会改变实例的ID或接入点。操作步骤登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择...

配额与限制

云消息队列 RocketMQ 版对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用云消息队列 RocketMQ 版时不要超过对应的限制值，避免应用出现异常。参数限制以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...

产品优势

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

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

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

路由到云消息队列 RabbitMQ 版

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

路由到云消息队列 Kafka 版

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

2020年

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

生产者负载均衡

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

使用ACL功能进行访问控制

当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用云消息队列 Kafka 版专业版实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息企业A购买了云消息队列 ...

事务消息

事务消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景分布式事务的诉求分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...

服务器证书管理

步骤三：使用服务器证书启动服务启动服务会重启云消息队列 MQTT 版实例，重启时间预计5～10分钟，重启后客户端即可使用服务器证书做服务端认证。启动服务后，8883端口将开启双向认证，同时关闭单向认证。警告使用服务器证书启动服务，...

步骤三：创建资源

当使用云消息队列 Kafka 版进行消息收发时，您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和...

作为Input接入

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

将云消息队列 Kafka 版接入阿里云Elasticsearch

云消息队列 Kafka 版云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。更...

作为Input接入

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

作为Input接入

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

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

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

Topic引流

您在升级云消息队列 Kafka 版实例的流量规格时，可能会触发集群横向扩容。集群横向扩容完成后，您需要进行Topic引流，使Topic流量重新均匀分布到扩容后的集群上。否则原有的Topic流量还是打在扩容前的集群节点上，原有的Topic的峰值流量...

常见问题

本文介绍与事件总线EventBridge 相关的基本问题。什么是事件总线...事件总线EventBridge 支持的阿里云产品的事件格式，请参见企业级分布式应用服务事件。如何配置事件模式过滤事件？关于如何配置事件模式，请参见管理事件规则。

作为Input接入

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

集群消费和广播消费

集群消费和广播消费是云消息队列 RocketMQ 版的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息云消息队列 ...

作为Output接入

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

作为Output接入

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

降低实例配置

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

创建DTS Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流入源为数据传输服务DTS的消息流入任务。前提条件您已购买云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和部署实例。在数据传输服务DTS控制台 ...

作为Output接入

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

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

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

数据传输服务DTS

本文介绍如何在云消息队列 RabbitMQ 版控制台创建消息流入任务，将数据传输服务DTS中的数据快速导入至云消息队列 RabbitMQ 版。前提条件您已购买云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。在...

分布队列双重总线怎么重启

新品推荐