消费者负载均衡
什么是消费者负载均衡 如上文所述，消费组间广播消费场景下，每个消费者分组内只有一个消费者，因此不涉及消费者的负载均衡。消费组内共享消费场景下，消费者分组内多个消费者共同分担消息，消息按照哪种逻辑分配给哪个消费者，就是由消费...
消费者（Consumer）
因此，为了保证分组内消息的正常负载和消费，云消息队列 RocketMQ 版 要求同一分组下的所有消费者以下消费行为保持一致：投递顺序 消费重试策略 版本兼容性 如行为约束中所述，同一分组内所有消费者的投递顺序和消费重试策略需要保持一致。...
队列服务订阅推送
consumers.list 是消费者列表，各个列的说明如下：参数 说明 Id 为消费者的ID全称，格式是<消费者组Id.消费者Id>。Index 为当前消费者正在消费的数据index。Pending 指示当前消费者正在处理，但没有进行Commit的数据数量。Status 消费者的...
基本概念
消费者分组（ConsumerGroup）消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者不同，消费者分组并不是运行实体，而是一个逻辑资源。在 云消息队列 RocketMQ 版 中，通过消费者分组内初始...
消费进度管理
消费位点初始值 消费位点初始值指的是消费者分组首次启动消费者消费消息时，服务端保存的消费位点的初始值。云消息队列 RocketMQ 版 定义消费位点的初始值为消费者首次获取消息时，该时刻队列中的最大消息位点。相当于消费者将从队列中最新...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
ConsumerGroupHeartBeat-消费者发送心跳到服务端
consumer_group_test consumer string 是 消费者。consumer_1 body array 是 正在消费的 Shard ID 列表。integer 是 正在消费的 Shard ID 列表。[0]返回参数 名称 类型 描述 示例值 headers object Date string 返回响应的时间。Sun,27 May...
ResetConsumeOffset-重置消费位点
dolphin_status topicName string 是 消费者分组订阅的主题名称。AMZN_REPORT_TOPIC body object 否 请求体对象。resetType string 否 重置方式。CLATEST_OFFSET：从最新位点开始消费。Group ID 消费指定 Topic 中的消息时，会跳过当前堆积...
Logstash消费
consumer_name string 是 消费者名称，同一个消费组中的消费者名称不能重复。position string 是 消费开始位置。begin：从Logstore写入的第一条数据开始消费。end：从当前时间点开始消费。yyyy-MM-dd HH:mm:ss：从指定时间点开始消费。...
通过消费组消费数据
public static void main(String[]args)throws LogHubClientWorkerException,InterruptedException {/consumer_1是消费者名称，同一个消费组下面的消费者名称必须不同。不同消费者在多台机器上启动多个进程，均衡消费一个Logstore时，消费...
通过消费组消费数据
public static void main(String[]args)throws LogHubClientWorkerException,InterruptedException {/consumer_1是消费者名称，同一个消费组下面的消费者名称必须不同。不同消费者在多台机器上启动多个进程，均衡消费一个Logstore时，消费...
产品优势
通过阿里云智能算法平台，帮助客户深度洞察消费者需求和行为，构建面向各行各业不同营销场景需求的数字化、程序化的广告投放及分析服务，达成数字化精准营销的目标。全方位营销方式：营销引擎云码 平台包含四大业务模块，在四大业务模块的...
ConsumerGroupUpdateCheckPoint-更新消费进度
consumer_group_test consumer string 是 消费者。consumer_1 forceSuccess boolean 否 是否强制更新。true：强制更新 false：不强制更新 false body object[]否 Shard ID。shard integer 是 Shard ID。0 checkpoint string 是 checkpoint ...
OnsMessagePush-向指定的消费者推送消息
GID_test_group_id ClientId string 是 消费者实例的 ID。您可调用 OnsConsumerGetConnection 接口获取该 ID。30.5.121.*@24813#-1999745829#-1737591554#453111174894656 MsgId string 是 消息的标识，即 Message ID。0BC1669963053CF68F...
通过可观测性能力进行故障处理最佳实践
查看消息处理耗时（rocketmq_process_time）和消息处理成功率（rocketmq_process_time_count{invocation_status="success"/invocation_status="success｜failure"}）等指标是否异常，初步定位是否是消费者客户端的问题。消息处理成功率=...
ListConsumerConnections-获取消费者客户端连接信息
rmq-cn-uax32mf9h1f consumerGroupId string 是 消费者分组 ID。GID_TEST_STOCK_OPEND_GW 返回参数 名称 类型 描述 示例值 object Result requestId string 请求 ID A3620115-6F1F-5CFB-AA3F-BBD4853B2EC4 success boolean 是否成功 true ...
订阅消息API
consumer 是 消费者群组的标识，即Group ID。tag 否 消息Tag。如果不指定Tag，则拉取所有消息。如果需要指定多个Tag，则使用双竖线（|）隔开，例如TagA|TagB。numOfMessages 是 一次最多消费多少条消息，取值范围：1～16。waitseconds 否 ...
节省计划常见问题
节省计划的每小时承诺消费是什么？购买节省计划即代表您承诺了一定的费用和时长，其中每小时承诺消费表示承诺的最小用量（单位为 元），在此数值范围内的小时账单将享受节省计划的特有折扣，且能被节省计划抵扣。如果您选择部分预付或者0...
开发入门
以上三种消费模式都受到checkpoint记录的影响，如果存在checkpoint记录，则从checkpoint处开始消费，不管指定的是什么消费模式。E-MapReduce SDK基于“SPECIAL_TIMER_CURSOR”模式支持用户强制在指定时间点开始消费，在LoghubUtils#...
鲜丰水果：3个月夯实基建，85%的需求两周内发布上线
用户价值驱动：各团队基于需求进行协作，每个需求都需要关注用户价值，一方面需要明确用户是谁，目标是什么，另一方需求需要被拆分到小颗粒度（一个需求开发测试完成要在两周内），当然对于小需求需要达到可测可发布。前后职能拉通：在需求...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
API概览
消费者分组 API 标题 API概述 CreateConsumerGroup 创建消费者分组 创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定...
概述
消费者集群 用来表示消费消息应用，一个消费者集群下包含多个消费者实例，可以是多台机器，也可以是多个进程，或者是一个进程的多个消费者对象。一个消费者集群下的多个消费者以均摊方式消费消息。如果设置的是广播方式，那么这个消费者...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
CreateConsumerGroup-创建消费者分组
创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明 注意 阿里云...
消费重试
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
什么是云消息队列 MQTT 版
消费者：也称为消息订阅者，负责从Topic接收并消费消息。消息：生产者向Topic发送并最终传送给消费者的数据。规则：云消息队列 MQTT 版 与其他阿里云产品实现数据互通的资源。消息收发模型 云消息队列 MQTT 版 主要包含以下两种消息收发...
更新网关鉴权消费者状态
更新网关鉴权消费者状态。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 示例值 ...
阿里云日志服务Splunk Add-on
一个消费组由多个消费者构成，同一个消费组下面的消费者共同消费一个Logstore中的数据，消费者之间不会重复消费数据。一个Logstore下面会有多个Shard。每个Shard只会分配到一个消费者。一个消费者可以同时拥有多个Shard。所创建的消费者...
UpdateGatewayAuthConsumer-更新网关鉴权消费者
更新网关鉴权消费者。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 示例值 ...
logstash-input-sls插件使用说明
自动负载均衡：根据消费者数量自动分配shard，消费者增加或退出后会自动进行负载均衡。前提条件 您已完成以下操作：安装logstash-input-sls插件。具体操作步骤请参见 安装或卸载插件。创建日志服务项目和Logstore，并采集数据。具体操作...
AddGatewayAuthConsumer-新增网关鉴权消费者
新增网关鉴权消费者。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 示例值 ...
GetGatewayAuthConsumerDetail-获取网关鉴权消费者细节
获取网关鉴权消费者细节。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
开发HSF应用（Pandora Boot）
HSF服务框架基于接口进行服务通信，当接口定义好之后，生产者将通过该接口实现具体的服务并发布，消费者也是基于此接口订阅和消费服务。public interface HelloService { String echo(String string);} 接口 ...
PaaS应用场景
应用场景 公测期间，新零售智能助理主要应用于零售行业消费者在线咨询的智能应答。当消费者咨询问题时，ISV调用新零售智能助理服务获取实时应答结果。RetailBot会根据消费者问题、上下文、知识库、机器人配置等多个因素，智能计算最优解并...
消息队列RocketMQ 5.0的审计事件
CreateConsumerGroup 创建消费者分组。DeleteTopic 删除主题。DeleteInstance 删除实例。DeleteConsumerGroup 删除消费者分组。UpdateTopic 更新主题。UpdateInstance 更新实例。UpdateConsumerGroup 更新消费者分组。ListTopics 查询主题...
协同消费
5 心跳 要实现协同消费的功能，需要通过心跳机制来通知让服务端消费者实例的状态，当前分配的shard和需要释放的shard，超过时间间隔没有收到心跳，则认为消费者实例已经停止。当消费者实例的状态发生改变，服务端会重新分配shard，新的分配...
使用SDK示例代码消费订阅数据
持久化后的消费位点是什么格式的数据？消费位点在持久化处理后，将返回JSON格式的数据。其中，持久化后的消费位点的格式为Unix时间戳，您可以直接将其传回SDK进行使用。如下返回数据中，"timestamp"后的 1700709977 即为持久化后的消费位点...
使用SDK示例代码消费订阅数据
持久化后的消费位点是什么格式的数据？消费位点在持久化处理后，将返回JSON格式的数据。其中，持久化后的消费位点的格式为Unix时间戳，您可以直接将其传回SDK进行使用。如下返回数据中，"timestamp"后的 1700709977 即为持久化后的消费位点...
- 产品推荐
- 这些文档可能帮助您