集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
集群消费和广播消费
本文介绍 SOFAStack 消息队列的集群消费和广播消费的基本概念、适用场景以及注意事项。消息队列是基于发布/订阅模型的消息系统。消费者，即消息的订阅方订阅关注的 Topic，以获取并消费消息。由于消费者应用一般是分布式系统，以集群方式...
顺序消息
与顺序消息相关的常见问题如下：顺序消息是否支持集群消费和广播消费？同一条消息是否可以既是顺序消息，同时又支持定时消息和事务消息？顺序消息支持哪些地域（Region）？顺序消息的使用范围是什么？顺序消息支持哪种消息发送方式？顺序...
版本说明
本发布说明（Release notes）按照时间倒序方式提供了 SOFAStack ...详见 集群消费和广播消费。提供简单易用的可视化 Web 控制台管理工具，支持 创建和管理 Topic、创建和管理 Group ID、查看订阅关系、重置消费位点、消息查询、查询消息轨迹。
基础术语
详情请参见 集群消费和广播消费。定时消息 Scheduled message Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 Consumer 进行消费，该消息即定时消息。详情请参见 定时和...
功能特性
集群消费和广播消费：当使用集群消费模式时，消息队列认为任意一条消息只需要被消费者集群内的任意一个消费者处理即可；当使用广播消费模式时，消息队列会将每条消息推送给消费者集群内所有注册过的消费者，保证消息至少被每台机器消费一次...
查看消费者状态
更多信息，请参见 集群消费和广播消费。实时消费速度 该Group ID下消费者实例群组接收消息的总TPS，单位为：条/秒。处理中消息量 在消费者客户端正在处理，但客户端还未返回消费结果的消息。就绪消息量 消息在 云消息队列 RocketMQ 版 服务...
订阅消息
两种不同的订阅方式有着不同的功能限制，例如，广播模式不支持顺序消息、不维护消费进度、不支持重置消费位点等，详情请参见 集群消费和广播消费。示例代码 具体的示例代码，请以 消息队列代码库 为准。import java.util.Properties;import...
基本概念
更多信息，请参见 集群消费和广播消费。定时消息 Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费，该消息即定时消息。更多信息，请参见...
OnsConsumerStatus-查询Group ID消费状态
取值说明如下：CLUSTERING：集群消费模式 BROADCASTING：广播消费模式 两种订阅模式的详细信息，请参见 集群消费和广播消费。CLUSTERING ConnectionSet object[]该集群当前在线客户端信息。RemoteIP string 宿主机 IP 地址或公网 IP 地址。...
常见问题
消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的消息体最大是多少？消息在消息队列RocketMQ版中能保存多久？消息的负载均衡策略是什么？消息消费失败是否会重新消费？消息...
功能与特性概述
集群消费和广播消费：当使用集群消费模式时，云消息队列 RocketMQ 版 认为任意一条消息只需要被消费者集群内的任意一个消费者处理即可；当使用广播消费模式时，云消息队列 RocketMQ 版 会将每条消息推送给消费者集群内所有注册过的消费者，...
订阅消息
两种不同的订阅方式有着不同的功能限制，例如，广播模式不支持顺序消息、不维护消费进度、不支持重置消费位点等，更多信息，请参见 集群消费和广播消费。示例代码#include"ONSFactory.h"#include<iostream>#include<thread>#include<mutex>...
常见问题
云消息队列 RocketMQ 版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？云消息队列 RocketMQ 版的消息体最大是多少？消息在云消息队列 RocketMQ 版中能保存多久？消息的负载均衡策略是什么？消息消费失败是否会...
顺序消息
顺序消息是否支持集群消费和广播消费？顺序消息暂时仅支持集群消费模式，不支持广播消费模式。TCP SDK示例代码 TCP协议下的示例代码请参见以下文档：Java：收发顺序消息 C/C++：收发顺序消息.NET： 收发顺序消息 HTTP SDK示例代码 HTTP协议...
订阅消息
两种不同的订阅方式有着不同的功能限制，例如，广播模式不支持顺序消息、不维护消费进度、不支持重置消费位点等，更多信息，请参见 集群消费和广播消费。消息获取方式 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push：消息由 云...
通过命令行管理多集群服务
管理员在服务提供者集群（ACK Cluster 1）和服务消费者集群（ACK Cluster 2）中，创建应用相关资源，包含Namespace、Deployment和Service；创建多集群Service资源，包括ServiceExport和ServiceImport。多集群舰队Fleet监听子集群的...
消费者负载均衡
广播消费和共享消费 在 云消息队列 RocketMQ 版 领域模型中，同一条消息支持被多个消费者分组订阅，同时，对于每个消费者分组可以初始化多个消费者。您可以根据消费者分组和消费者的不同组合，实现以下两种不同的消费效果：消费组间广播...
API概览
资源管理 API 标题 API概述 ECS集群和K8s集群 ECS集群和K8s集群 DeleteUserDefineRegion 删除指定的自定义命名空间 删除指定的自定义命名空间。DeleteCluster 删除集群 用于删除ECS集群或取消导入K8s集群。ListAliyunRegion 获取阿里云地域...
通过控制台管理多集群服务
管理员在服务提供者集群（ACK Cluster 1）和服务消费者集群（ACK Cluster 2）中，创建应用相关资源，包含Namespace、Deployment和Service；创建多集群Service资源，包括ServiceExport和ServiceImport。多集群舰队Fleet监听子集群的...
迁移数据上云
如下图所示，Mirror Maker使用一个内置的Consumer从源自建Kafka集群消费消息，然后再使用一个内置的Producer将这些消息重新发送到目标 云消息队列 Kafka 版 集群。更多信息，请参见 Apache Kafka MirrorMaker。注意事项 Topic名称必须一致...
迁移上云操作
读流量访问源集群 写流量访问源集群 写源集群冗余读 读流量同时访问目标集群和源集群 写流量还是访问源集群 写目标集群冗余读 读流量同时访问源集群和目标集群 写流量从源集群切换至目标集群 此阶段目标集群会同时有消息生产和消息消费流量...
消息重试
广播消费模式不提供失败重试特性，即消费失败后，失败消息不再重试，继续消费新的消息。消息重试策略概述 云消息队列 RocketMQ 版 消息收发过程中，若Consumer消费某条消息失败或消费超时，则 云消息队列 RocketMQ 版 会在重试间隔时间后，...
消息重试
配置方式 消费失败后，重试配置方式 集群消费方式下，消息消费失败后期望消息重试，需要在消息监听器接口的实现中明确进行配置（三种方式任选一种）：返回 Action.ReconsumeLater（推荐）返回 Null 抛出异常 示例代码：public class ...
重置消费位点
请确认是否为集群消费。广播模式不支持重置消费位点。确认当前消费者是否在线。消费者必须在线才能重置消费位点。确认SDK版本，SDK版本过低也会导致此问题。建议升级SDK至最新版本，针对TCP Java SDK，至少是1.8.0.Final及以上版本。更多...
SOFAMQ 常见问题
每次重试的间隔时间如下：第几次重试 每次重试间隔时间 1 10 秒 2 30 秒 3 1 分钟 4 2 分钟 5 3 分钟 6 4 分钟 7 5 分钟 8 6 分钟 9 7 分钟 10 8 分钟 11 9 分钟 12 10 分钟 13 20 分钟 14 30 分钟 15 1 小时 16 2 小时 广播消费方式 广播...
概述
应用场景 异步解耦消息队列的生产消费模型可以解耦上下游业务系统，并支持下游多个消费者对同一消息进行消费和处理。以金融场景为例，支付中心作为支付宝主站最核心的系统，每笔支付数据的产生会引起几百个下游业务系统的关注，包括账户...
查看和修改集群信息
修改集群信息 集群创建后，您可根据业务需求修改集群名称和集群描述信息，以便更好的分类管理集群。登录 弹性高性能计算控制台。在顶部菜单栏左上角处，选择地域。在左侧导航栏，单击 集群。在 集群 页面，找到需要修改的集群，单击 更多>...
首次使用容器服务Kubernetes版
AliyunCSManagedCostRole ACK托管集群 和 ACK Serverless集群 的成本分析组件使用该角色访问您在账单管理API、ECS和ECI服务中的资源。AliyunCSManagedNimitzRole ACK灵骏集群 的网络组件使用该角色访问您在智能计算灵骏服务中的资源。...
设置集群参数和节点参数
导出为模板生成的集群参数由您手动修改的参数和集群在运行过程中自动修改的参数组成。在弹出的 应用模板 对话框中，设置以下参数。参数 说明 模板名称 模板的名称。名称需要满足以下规则：由英文、数字、和下划线（_）组成，以字母开头，不...
AIOps套件概述
AIOps套件包括集群检查、集群巡检和集群诊断，可以帮助您排查问题，提升运维效率。本文介绍AIOps套件的优势、集群检查、集群巡检和集群诊断。优势 AIOps套件由集群检查、集群巡检、集群诊断等一系列工具组成，具有以下优势。功能 优势 集群...
ACK One计费说明
不支持 不支持 计费说明 SLS日志服务 建议项 用于集群组件和应用的日志采集和检索。更多信息，请参见 什么是日志服务。不支持 支持 可参考如下文档，根据业务需要选购合适的资源包：选购资源包。计费概述 阿里云Prometheus 建议项 基于...
AIOps套件概述
AIOps套件包括集群检查、集群巡检和集群诊断，可以帮助您排查问题，提升运维效率。本文介绍AIOps套件优势、集群检查、集群巡检和集群诊断。索引 优势 集群检查 集群巡检 集群诊断 优势 AIOps套件由集群检查、集群巡检、集群诊断等一系列...
通过注册集群统一管理任意环境下的Kubernetes集群
注册集群帮助您将云下Kubernetes集群接入云端，快速搭建混合云集群，同时支持本地数据中心Kubernetes集群或其他云厂商Kubernetes集群接入阿里云容器服务管理平台，进行统一管理。本文介绍注册集群如何统一管理任意环境下的Kubernetes集群。...
跨集群访问JindoFS
例如，集群A需要关联集群B和集群C，B集群（rocksdb实现）地址为 emr-header-1.<cluster-B>:8101，C集群（raft实现）地址为 emr-header-1.<cluster-C>:8101,emr-header-2.<cluster-C>:8101,emr-header-3.<cluster-C>:8101 那A集群需要添加的...
基于ACK One构建混合云同城容灾系统
对于当前业务运行在IDC或第三方公共云的Kubernetes集群中的系统架构，如果希望通过云计算为云下业务提供同城灾备的高可用冗余能力，可利用阿里云 分布式云容器平台 ACK One 来提供统一的流量、应用和集群管理，实现业务流量的多集群路由和...
查看集群列表与详情
前提条件 已创建集群，详情请参见 创建集群。查看集群列表 登录 E-MapReduce控制台。...安全 该区域为您展示密钥对、ECS实例角色、集群安全组和集群服务角色等信息。相关文档 查看集群详细信息，请参见 ListClusters-查询集群。
云数据库ClickHouse集群间的数据迁移
源集群可迁移内容包含：集群、库、表、数据字典、物化视图、用户权限和集群配置。非MergeTree类型的表（例如，外表、Log表等）仅支持迁移表结构。因此当源集群存在非MergeTree类型的表时，若您使用数据迁移功能，目标集群中非MergeTree类型...
升级内核大版本
说明 源集群可迁移内容包含：集群、库、表、数据字典、物化视图、用户权限和集群配置。迁移任务配置完成后，后台进行迁移链路预检测并启动任务。校验成功，单击 完成。校验失败，您需要按照提示信息进行操作，重新进行数据迁移。检测项目及...
使用指引
集群运维 应用运维 集群管理 升级集群和独立升级集群控制面和节点池 扩容ACK集群的节点 管理组件 节点维护 添加已有节点 设置节点调度 批量运维节点 节点池管理 创建节点池 调度应用至指定节点池 配置节点池内抢占式实例和存量实例的比例 ...
- 产品推荐
- 这些文档可能帮助您