查看消费者状态

就绪消息量 消息在 云消息队列 RocketMQ 版 服务端已就绪,对消费者可见可被消费的消息。排队时间 最早一条就绪消息的就绪时间和当前时刻的时间差。该时间反映消费者拉取消息的及时性。订阅关系 显示该Group ID下消费者实例群组的订阅关系...

概述

应用场景 异步解耦消息队列的生产消费模型可以解耦上下游业务系统,并支持下游多个消费者对同一消息进行消费和处理。以金融场景为例,支付中心作为支付宝主站最核心的系统,每笔支付数据的产生会引起几百个下游业务系统的关注,包括账户...

配置路由认证和消费者鉴权

消费者说明 对消费者进行描述。认证方式 当前消费者支持的认证方式。密钥类型 对称密钥:生成一份默认的JWKS配置(每个消费者不同),包含加密或者解密Token时使用的密钥。非对称密钥:需要您自己填写完整的JWKS配置,使用私钥加密Token。...

消费幂等

为了防止消息重复消费导致业务处理异常,消息队列RocketMQ版 的消费者在接收到消息后,有必要根据业务上的唯一Key消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...

集群消费和广播消费

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

重置消费位点

重置消费位点功能只能重置对消费者可见的消息,不能重置定时中、重试等待中的消息。重试消费位点只能在消费者在线时进行操作。操作步骤 登录 云消息队列 RocketMQ 版 控制台,在左侧导航栏单击 实例列表。在顶部菜单栏选择地域,如 华东1...

消息幂等

为了防止消息重复消费导致业务处理异常,SOFAStack 消息队列的消费者在接收到消息后,有必要根据业务上的唯一 Key 消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...

仪表盘

最晚一条拉取消息的位点-最晚一条提交消息的位点 已就绪的消息(ready messages)消息在 云消息队列 RocketMQ 版 服务端已就绪,对消费者可见可被消费的消息。最大消息位点-最晚一条拉取消息的位点 消息堆积量(consumer lag)所有未处理...

定时/延时消息

定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和...定时消息到达定时时间后才对消费者可见,并在控制台查询到消息轨迹。

仪表盘

最晚一条拉取消息的位点-最晚一条提交消息的位点 已就绪的消息(ready messages)消息在 云消息队列 RocketMQ 版 服务端已就绪,对消费者可见可被消费的消息。最大消息位点-最晚一条拉取消息的位点 消息堆积量(consumer lag)所有未处理...

消息负载均衡策略

对消费者而言,消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级,云消息队列 RocketMQ 版 的负载均衡策略也有所优化,根据SDK版本,负载均衡策略可分为:负载均衡策略(客户端Java v2.x.x.Final和C++ v3.x.x)负载...

智能导购企微版概述

智能导购企微版深度融合企业微信,赋能导购高效运营消费者,助力企业降本提效。在消费升级的背景下,消费者的消费场景发生了转移,尤其在新冠疫情影响之下,线下流量告急,线上流量经营引起众多泛零售企业的关注,如何利用私域流量获得业绩...

服务提供方或消费方流控

例如,资源A可以大部分消费者可以每秒提供10个请求,但是对于消费者caller1是个例外,caller1,每秒可以提供200个请求。需配置两条规则,说明如下:为消费者caller1配置一条 limitApp 为caller1的限流规则,这条规则每秒的最大请求量...

基本概念

重置消费位点 以时间轴为坐标,在消息持久化存储的时间范围内,重新设置消费者分组已订阅主题的消费进度,设置完成后消费者将接收设定时间点之后,由生产者发送到 云消息队列 RocketMQ 版 服务端的消息。更多信息,请参见 重置消费位点。...

集群消费和广播消费

由于消费者应用一般是分布式系统,以集群方式部署,因此消息队列约定以下概念:集群:使用相同 Group ID 的消费者属于同一个集群。同一个集群下的消费者消费逻辑必须完全一致(包括 Tag 的使用)。详情请参见 订阅关系一致。集群消费:当...

服务提供方或消费方流控

例如,资源 A 可以大部分消费者可以每秒提供 10 个请求,但是对于消费者 caller1 是个例外, caller1,每秒可以提供 200 个请求。需配置两条规则,说明如下:为消费者 caller1 配置一条 limitApp 为 caller1 的限流规则,这条规则每秒...

2022/09/08 更新日志

二、OpenAPI 密钥操作增加审计日志 OpenAPI 密钥操作增加审计日志,操作类型包含:创建Open API密钥,禁用Open API密钥,启用Open API密钥,删除Open API密钥,发送短信验证码。三、订单详情和客户详情新增售后信息 用户可以在...

查看消费者状态

如果消息消费异常,您可以在 SOFAStack 消息队列控制台查看消费者状态,进行问题排查。本文介绍如何查看消费者状态。查看 Group ID 消费者状态 登录 SOFAStack 控制台。在左侧导航栏,选择 中间件>消息队列>Group 管理。单击目标 Group ID ...

队列服务订阅推送

在不同的消费者组间,数据会并列地推送给每一个存在的消费者,举例来看:如果您的多个消费者在同一个组内,您可以观察到数据会在这些消费者之间进行均衡地分发,消费者会收到不同的数据。如果您的多个消费者在多个不同的组内,您可以观察到...

API概览

消费者分组 API 标题 API概述 CreateConsumerGroup 创建消费者分组 创建云消息队列 RocketMQ 版的消费者分组(ConsumerGroup)。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定...

迁移消费者程序

若您创建消费者程序时使用Assign方式消费消息,请先在源集群停止旧消费者程序,旧消费者程序停止后,迁移组件也会停止同步旧消费者程序所用的消费组的消费位点,然后再在目标实例启动新消费者程序。若您无法确定消费者程序使用哪种消费方式...

消费组监控与告警

背景信息 一个消费组包含多个消费者,每个消费者消费Logstore中的一部分Shard。同一个消费组下面的消费者共同消费一个Logstore中的日志数据,消费者之间不会重复消费数据。Shard数据模型可以简单理解为一个队列,新写入的数据被加到队尾,...

ListConsumerGroupSubscriptions-查询消费者组订阅...

查询指定消费者组的订阅关系。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息,可以在RAM权限策略语句的 Action ...

服务管控

您可以在控制台查看当前工作空间下所有已发布并启用了服务网格的应用服务,包括查看服务详细信息、服务提供者信息、服务消费者信息等。操作步骤 登录 SOFAStack 控制台。在左侧菜单栏选择 中间件>微服务平台>服务网格>服务管控。在服务管控...

消息轨迹

是否顺序投递 消费者所属的消费者分组是否开启顺序消费。投递时间 云消息队列 RocketMQ 版 服务端将消息投递给消费者的时间。应答时间 云消息队列 RocketMQ 版 收到消费者返回的消费结果的时间。invisibleDuration SimpleConsumer传入的...

DATASOURCE:ROCKETMQ5:ConsumerGroups

DATASOURCE:ROCKETMQ5:ConsumerGroups类型用于查询ROCKETMQ5.0系列的消费者分组。语法 {"Type":"DATASOURCE:ROCKETMQ5:ConsumerGroups","Properties":{"InstanceId":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 InstanceId ...

为Dubbo服务动态配置超时时间

针对消费者应用 选择针对当前服务的消费者应用,星号(*)表示所有消费者应用。超时时间 设置调用的超时时间,超时时间应设置为大于0的整数,单位:ms。此配置优先级高于其他同级别配置。超时配置优先级关系参考:相较于其他配置优先级:...

CreateConsumerGroup-创建消费者分组

创建云消息队列 RocketMQ 版的消费者分组(ConsumerGroup)。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明 注意 阿里云...

GetConsumerGroup-获取指定消费者分组详情

获取某个指定消费者分组的详细信息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致链路产生风险。调试...

ConsumerGroupHeartBeat

调用ConsumerGroupHeartBeat接口为指定消费者发送心跳到服务端。接口说明 Host由Project名称和日志服务Endpoint构成,您需要在Host中指定Project。消费者和服务端通过固定时间发送心跳建立连接。在固定时间段内没有收到心跳,消费者将被...

准备RAM用户

例如,在使用Dataphin过程中,某企业规划不同的员工负责数据开发、数据运维、数据分析阶段的工作,并且企业管理者对员工间的权限控制和数据安全有要求。因此,您可以创建3个RAM用户,将RAM用户同步至Dataphin后,添加为项目空间的成员并...

混合部署应用(ECS和K8s环境)

当您需要分离不同形态的应用或者做应用架构迁移时,可以将服务的提供者与消费者分别部署到同一VPC的ECS环境和K8s环境,他们提供的服务也是可以相互发现和调用的。前提条件 请确保您混合部署应用的ECS集群和K8s集群属于同一个VPC,且在EDAS...

使用Confluent-Kafka-Go实现Kafka消费

在这个时间间隔内加入组的消费者为消费组的成员,进行分区分配,各个消费者按分配的分区开发消费数据,如果在这个时间内还有消费者没有加入消费组,则会触发消费组再平衡操作,再平衡期间不会消费数据,会导致消费延迟。建议设置max.poll....

ALIYUN:ROCKETMQ5:ConsumerGroup

ALIYUN:ROCKETMQ5:ConsumerGroup类型用于创建ROCKETMQ5.0系列的消费者分组。语法 {"Type":"ALIYUN:ROCKETMQ5:ConsumerGroup","Properties":{"ConsumerGroupId":String,"InstanceId":String,"ConsumeRetryPolicy":Map,"DeliveryOrderType":...

通过命令行管理多集群服务

方式一:通过新的Service名称访问 服务消费者集群ACK Cluster 2创建ServiceImport后,Fleet实例会在服务消费者集群ACK Cluster 2中,创建一个以 amcs-为前缀的Kubernetes服务代表多集群Service。在服务消费者集群ACK Cluster 2的Client Pod...

使用Confluent-Kafka-Python实现Kafka消费

在这个时间间隔内加入组的消费者为消费组的成员,进行分区分配,各个消费者按分配的分区开发消费数据,如果在这个时间内还有消费者没有加入消费组,则会触发消费组再平衡操作,再平衡期间不会消费数据,会导致消费延迟。重要 使用confluent...

无损下线

为了避免这种情况的发生,在提供者A接到下线命令即将下线前,对于在等待下线阶段收到的请求,在其返回值中都增加上特殊标记,让消费者A接收到返回值并识别到相关标志后主动拉取一次注册中心服务实例,从而实时感知提供者A最新状态,从而...

API 概览

消费管理 API 描述 QueryMqSofamqConsumerAccumulate 查询消费者消息积压 GetMqSofamqConsumerStatus 查询消费端详细状态 GetMqSofamqConsumerJStack 查询消费端堆栈信息 QueryMqSofamqConsumerConnection 查询消费者连接信息 ...

为什么在控制台看不到消费者的客户端信息?

问题现象 在 云消息队列 Kafka 版 控制台 ...您采用 assign 方式手动指定消费者读取某个Topic分区的消息,订阅关系已经明确,开源Kafka没有统计此信息。只有您采用 subscribe 方式自动分配分区与消费者的订阅关系,客户端的具体信息才会显示。

UpdateConsumerOffset-重置消费者组的消费位点

通过 UpdateConsumerOffset 重置消费者组的消费位点。接口说明 此接口用于重置指定消费组的消费位点,支持以 timestamp 和 offset 的方式重置消费者组的消费位点。通过传入不同参数的组合可以实现如下功能:支持从最新位点开始消费,将消费...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
阿里邮箱 域名 短信服务 商标服务 数据库备份 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用