队列服务订阅推送
消费者组 消费者组是以相同过滤条件订阅队列服务的消费者的集合，不同组内的消费者可以同名，同组内的消费者不可以同名。在同一个消费者组内，数据将会均衡地分发给各个消费者；在不同的消费者组间，数据会并列地推送给每一个存在的消费者...
ConsumerGroupHeartBeat
请求参数中的Shard实际分配的消费者，与请求参数中的消费者不一致。可能原因是和服务端心跳断开后，Shard已经分配给其他消费者，建议传入空Shard列表。404 ProjectNotExist Project does not exist.Project不存在。404 LogStoreNotExist ...
常见问题
消费者不重启，会一直保存。是否只有 Registry 扩缩容才会涉及 ACVIP 配置变更？只有注册中心的 SessionServer 扩缩容，才需要变更 ACVIP 的配置。ACVIP上已经有的数据不会自动变更，您可以通过 OSP 刷新已经有的数据，或进入 cloudinc ...
事务消息
此时消息对下游消费者不可见。消息回滚 第二阶段如果事务执行结果明确为回滚，服务端会将半事务消息回滚，该事务消息流程终止。提交待消费 第二阶段如果事务执行结果明确为提交，服务端会将半事务消息重新存储到普通存储系统中，此时消息对...
阿里云日志服务Splunk Add-on
所创建的消费者名字是由消费组名、host名、进程名、event协议类型组合而成，保证同一消费组内的消费者不重名。更多关于消费组的信息，请参见 通过消费组消费数据。准备工作 获取日志服务的AccessKey。您可以通过阿里云RAM获取日志服务...
消息存储和清理机制
当消费者不在线或消息消费异常时，会造成队列中大量消息堆积，且该现象暂时无法有效控制。若此时按照消费状态考虑将未消费的消息全部保留，则很容易导致存储空间不足，进而影响到新消息的读写速度。根据统一地存储时长管理消息，可以帮助...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。...消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息会不会丢失？订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。...消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息会不会丢失？订阅消息时消息Tag是否可以为空？创建新的消费分组订阅旧的Topic，如何设置消费起始位置？
消费者（Consumer）
因此，大部分场景下，单一进程内同一个消费分组只需要初始化唯一的一个消费者即可，开发过程中应避免以相同的配置初始化多个消费者。不建议频繁创建和销毁消费者 云消息队列 RocketMQ 版 的消费者是可以重复利用的底层资源，类似数据库的...
MNS如何保证多个消费者访问同一消息队列，不会丢失...
本文介绍 消息服务MNS 如何保证多个消费者访问同一消息队列，不会丢失消息...如果消费者在不可见时间内未完成消费，则需要发送不可见时间段的延长请求（ChangeVisibilityTimeout），否则消息将会在不可见时间段结束后重新被其他消费者取出。
消费者分类
背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同消费者类型，每种消费者类型的集成方式和控制方式都不一样。了解如下问题，可以帮助您选择更匹配业务场景的消费者类型。如何实现并发消费：消费者如何使用并发的多线程机制...
TCP协议客户端大版本发布
该策略可能会出现以下问题：消费者数量比和Queue数量多时，部分消费者获取不到消息的现象。部分消费者异常或者处理缓慢，其他消费者空闲却无法共同分担堆积压力的情况。以消息为粒度进行负载，负载策略更加均衡。避免了队列级负载策略可能...
配置消息灰度
如果您希望基线环境能够智能地识别其他环境是否存在消费者，在不存在消费者时消费对应环境的消息，在存在消费者时忽略对应环境的消息，请在 未打标环境忽略的标签 中输入 自动识别。说明 应用在开启消息灰度后，需要重启才能生效。未打标...
服务提供方或消费方流控
这个场景适用于资源对大部分消费者都有一个通用的阈值，对特定消费者有不一样的阈值的场景。例如，资源A可以对大部分消费者可以每秒提供10个请求，但是对于消费者caller1是个例外，对caller1，每秒可以提供200个请求。需配置两条规则，说明...
服务提供方或消费方流控
这个场景适用于资源对大部分消费者都有一个通用的阈值，对特定消费者有不一样的阈值的场景。例如，资源 A 可以对大部分消费者可以每秒提供 10 个请求，但是对于消费者 caller1 是个例外，对 caller1，每秒可以提供 200 个请求。需配置两条...
查看消费者状态
若该 Group ID 下所有消费者实例都不在线，则显示离线。实时消费速度：该 Group ID 下消费者群组接收消息的总 TPS，单位为“条/秒”。实时消息堆积量：该 Group ID 下消费者群组的未消费消息的总量。最近消费时间：该 Group ID 下消费者群...
顺序消息
但一般业务场景下，同一个生产者可能对接多个下游消费者，不一定所有的消费者业务都需要顺序消费，您可以将生产顺序性和消费顺序性进行差异化组合，应用于不同的业务场景。例如发送顺序消息，但使用非顺序的并发消费方式来提高吞吐能力。更...
Logstash消费
consumer_name string 是 消费者名称，同一个消费组中的消费者名称不能重复。position string 是 消费开始位置。begin：从Logstore写入的第一条数据开始消费。end：从当前时间点开始消费。yyyy-MM-dd HH:mm:ss：从指定时间点开始消费。...
OnsGroupSubDetail-查看Group ID的订阅信息
SubscriptionDataList object[]如果 Group ID 所对应的消费者不在线则查不到数据。SubString string 订阅表达式。Topic string 订阅的 Topic。test-mq_topic GroupId string 需查询的 Group ID。GID_test_group_id MessageModel string ...
查看消费者状态
若该Group ID下所有消费者实例都不在线，则显示 离线，且 客户端连接信息 区域无信息显示。消费模式 消费者订阅消息时使用的消费模式。云消息队列 RocketMQ 版 支持集群消费模式和广播消费模式，默认使用集群消费模式，消费模式可在消费者...
ConsumerGroupUpdateCheckPoint
接口说明 当不指定消费者时，必须指定 forceSuccess 为 true 才能更新checkpoint。Host由Project名称和日志服务Endpoint构成，您需要在Host中指定Project。已创建并获取AccessKey。更多信息，请参见 访问密钥。阿里云账号AccessKey拥有所有...
logstash-input-sls插件使用说明
同一个消费组内消费者名不能重复，否则会出现未定义行为。position String 是 消费位置，可选：begin：从日志库写入的第一条数据开始消费。end：从当前时间点开始消费。yyyy-MM-dd HH:mm:ss：从指定时间点开始消费。checkpoint_second ...
API概览
OnsGroupSubDetail 查看Group ID的订阅信息 查看Group订阅了哪些Topic，如果Group ID对应的消费者实例不在线则查不到数据。OnsGroupDelete 删除Group 调用OnsGroupDelete删除Group。标签 API 标题 API概述 ListTagResources 查询资源绑定的...
常见问题
为什么在控制台看不到消费者的客户端信息？为什么在控制台看不到Group的订阅关系？为什么消费位点过期了却仍未被删除？为什么同一个分区被多个消费线程消费了？为什么Group管理页面的Group变多了？为什么Group的状态一直处于“删除中”？为...
消息队列Kafka
false：直接启动作业，不检查消费者组冲突。说明 仅VVR 6.0.4及以后版本支持该参数。结果表 参数 说明 数据类型 是否必填 默认值 备注 topic 写入的topic名称。String 是 无 无 sink.partitioner 从Flink并发到Kafka分区的映射模式。String...
消费者分组（ConsumerGroup）
RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发投递，不同业务场景不能混用消费者分组。...
迁移消费者程序
如果不停止旧消费者程序，那么当新消费者程序全部停止后，迁移组件会继续同步消费位点，产生不可预知的问题，例如覆盖新消费者程序提交的位点。若您创建消费者程序时使用Assign方式消费消息，请先在源集群停止旧消费者程序，旧消费者程序...
查看Rebalance详情
消费出现卡顿，导致消费者心跳超时，触发Rebalance来筛选不健康的消费者。消费时间过慢，超过一定时间（max.poll.interval.ms 设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。消费者数量过多，为...
基本概念
消费者分组（ConsumerGroup）消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者不同，消费者分组并不是运行实体，而是一个逻辑资源。在 云消息队列 RocketMQ 版 中，通过消费者分组内初始...
订阅关系一致
订阅关系一致指的是同一个消费者 Group ID 下所有消费者实例所订阅的 Topic、Tag 以及对消息的处理逻辑必须完全一致。一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。本文提供订阅关系不一致的示例代码，帮助您顺畅地订阅...
消息收发常见问题
如果Topic被消费者订阅过，消费者离线后，若设置了离线消息，这些离线消息会在消费者再次上线后被消费到。为什么客户端消费时部分Topic的消息接收不到？云消息队列 MQTT 版 对单个客户端订阅的Topic数量和订阅关系的数量均有限制，若超过...
用户洞察概述
品牌数据银行、达摩盘、Kafka推送：支持将企业的一方标签数据、AIPL模型、受众人群推送到 数据银行，支持将受众人群推送到 达摩盘、阿里云Kafka 或开源Kafka，进而实现线上线下融合消费者分析和线上二次触达，为企业品牌全域消费者运营提能...
消费者负载均衡
消费者获取某条消息后，服务端会将该消息加锁，保证这条消息对其他消费者不可见，直到该消息消费成功或消费超时。因此，即使多个消费者同时消费同一队列的消息，服务端也可保证消息不会被多个消费者重复消费。顺序消息负载机制 在顺序消息...
用户洞察概述
支持将人群推送至 数据银行、达摩盘、阿里云Kafka 或开源Kafka，进而实现线上线下融合消费者分析和线上二次触达，为企业品牌全域消费者运营提能提效。自助分析：与 Quick BI数据可视化分析平台专业版 对接，支持在Quick Audience围绕人群...
死信队列
达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。在消息队列中，这种正常情况下无法被消费的消息称为死信消息（Dead-...
死信队列
当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法处理这些死信消息，为避免到期后死信消息被删除，您也可以先将死信消息导出进行保存。背景信息 当一条消息初次消费失败，云消息队列 RocketMQ 版 会...
数据银行推送快速入门
Quick Audience支持将人群关联的用户ID和标签、AIPL模型的用户ID推送至您的品牌数据银行，在数据银行进行基于品牌的全域消费者资产管理和分析，以及把人群应用到阿里域内的各种营销渠道，实现线上线下融合消费者分析和线上二次触达，提能提...
通过HTTPS投递日志到SIEM
consumer_name="{0}-{1}".format(consumer_group,current_process().pid)#心跳时长，当服务器在2倍时间内没有收到特定Shard的心跳报告时，服务器会认为对应消费者离线并重新调配任务。所以当网络环境不佳时，不建议将时长设置的比较小。...
通过Syslog投递日志到SIEM
consumer_name="{0}-{1}".format(consumer_group,current_process().pid)#心跳时长，当服务器在2倍时间内没有收到特定Shard的心跳报告时，服务器会认为对应消费者离线并重新调配任务。所以当网络环境不佳的时候，不建议将时长设置的比较小...
逻辑解码概念
复制槽可以在崩溃时保持，并且不知道其消费者的状态。即便没有连接使用它们，它们也将阻止移除所需的资源。这会消耗存储，因为只要还有一个复制槽需要，WAL 和来自于系统目录的行就不能被 VACUUM 移除。在极端情况下这会导致数据库关闭以...
- 产品推荐
- 这些文档可能帮助您