UpdateConsumerOffset-重置消费者组的消费位点
通过 UpdateConsumerOffset 重置消费者组的消费位点。接口说明 此接口用于重置指定消费组的消费位点，支持以 timestamp 和 offset 的方式重置消费者组的消费位点。通过传入不同参数的组合可以实现如下功能：支持从最新位点开始消费，将消费...
删除Group后仍然收到消息堆积的告警信息
解决方案 删除 Group 后，如果您不希望继续收到消息堆积的告警信息，请参见以下操作进行处理：确认服务端版本，请根据服务端版本情况执行以下操作：2.2.0及以上版本，请根据以下方式操作：若 Group 中没有存活的消费者线程（存活的消费者...
消息轨迹
消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端，再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期，您可以通过查询消息轨迹，快速分析和定位问题，及时...
HSF如何设置超时时间？
消费者（客户端）methodSpecials>消费者（客户端）clientTimeout>提供者（服务端）methodSpecials>提供者（服务端）clientTimeout。Consumer标签配置示例如下：...
DeleteConsumerGroup-删除消费者分组
删除指定的消费者分组。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。删除指定消费者...
UpdateConsumerGroup-更新消费者分组
更新消费者分组的基础信息和消费重试策略。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险...
使用Java实现Kafka消费
在这个时间间隔内加入组的消费者为消费组的成员，进行分区分配，各个消费者按分配的分区开发消费数据，如果在这个时间内还有消费者没有加入消费组，则会触发消费组再平衡操作，再平衡期间不会消费数据，会导致消费延迟。建议设置max.poll....
ResetConsumeOffset-重置消费位点
重置指定消费者分组的消费位点。重置消费位点是指改变订阅者当前的消费位置。当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点重新开始消费，您也可以将消费位置移动至最新位点，暂时不处理堆积的...
ListConsumerGroups-查询消费者分组列表
查询指定实例下消费者分组的列表信息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。...
GetServiceConsumersPage-查询微服务消费者列表
获取服务消费者列表。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素...
Logstash消费
自动负载均衡：根据消费者数量自动分配Shard，消费者增加或减少后会自动负载均衡。操作步骤 安装Logstash。下载安装包。解压安装包到指定目录。安装input插件。下载input插件。下载地址为 logstash-input-sls。安装input插件。logstash-...
通过消费组消费数据
通过消费组（ConsumerGroup）消费数据有显著优点，您无需关注日志服务的实现细节及消费者之间的负载均衡、故障转移（Failover）等，只需要专注于业务逻辑。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户并完成授权。已...
通过消费组消费数据
通过消费组（ConsumerGroup）消费数据有显著优点，您无需关注日志服务的实现细节及消费者之间的负载均衡、故障转移（Failover）等，只需要专注于业务逻辑。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户及授权。已...
使用Sarama-Kafka-Go实现Kafka消费
isPaused }/Consumer表示Sarama消费者组消费者 type Consumer struct { ready chan bool }/Setup在新会话开始时运行，在ConsumeClaim之前 func(consumer*Consumer)Setup(sarama.ConsumerGroupSession)error {/将消费者标记为已准备好 close...
授权管理
企业拥有者、通义灵码管理员可在通义灵码控制台中进行开发者的授权管理，已授权的企业成员可以使用通义灵码 IDE 插件。重要 使用通义灵码企业版，需要确保开发者将通义灵码 IDE 插件 更新到 v1.2.0，前往 下载和安装指南。准备工作 确认...
update_consumer_group
若服务端在超时时间段内没有收到消费者发送的心跳消息，则服务端删除该消费者占用相关资源。in_order Boolean 否 true 在单个Shard中是否按顺序消费。true：表示在单个Shard中按顺序消费。Shard分裂后，先消费原Shard数据，然后并列消费两...
create_consumer_group
若服务端在超时时间段内没有收到消费者发送的心跳消息，则服务端删除该消费者占用相关资源。in_order Boolean 否 true 在单个Shard中是否按顺序消费。true：表示在单个Shard中按顺序消费。Shard分裂后，先消费原Shard数据，然后并列消费两...
配置同可用区优先路由
在服务消费者调用服务提供者时，如果您的服务提供者是跨可用区部署的，那么您可以为服务提供者开启同可用区优先路由功能。该功能可以优先调用同可用区的服务提供者，从而避免服务之间跨可用区调用导致的网络延迟问题，缩短HTTP响应时间。...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
ConsumerGroup
在超时时间段内没有收到心跳，消费者将被删除。单位：秒。300 order boolean 是否按顺序消费。true：在 Shard 中按顺序消费。Shard 分裂后，先消费原 Shard 中数据，然后同时消费由该 Shard 分裂的 Shard 中数据。Shard 合并后，先消费原 ...
重置消费位点
当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点或者指定分区位点，重新开始消费。您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。前提条件 已停止所有Consumer客户端（云消息队列 ...
如何配置客户端参数？
消费者客户端参数 参数 说明 fetch.min.bytes 消费者从服务端获取数据的最小字节数。设置该参数时请尽量评估消息发送端的消息量，若设置过大可能会导致消费端延迟增大，过小可能会导致消费端频繁拉取消息。单位：字节。fetch.max.wait.ms ...
从Kafka同步数据
消费者的总数不应超过Topic中的分区数，因为每个分区只能分配一个消费者。kafka_thread_per_consumer 否 指定每个消费者是否启动独立线程进行消费，默认值为0。取值说明如下。0：表示所有消费者共同使用1个线程消费。1：表示每个消费者启动...
Pod动态上下线
在线上微服务场景中，当服务提供者的某些实例出现异常时，一方面，需要避免服务消费者访问到异常实例，另一方面，需要保留异常现场，便于后续的问题排查。本文介绍如何将异常Pod实例下线，帮助您及时将异常实例从注册中心摘除。操作步骤 ...
管理AMQP消费组
消费组是消息消费端的身份标识，多个消费者组成消息消费组接入物联网平台。设置AMQP服务端订阅后，物联网平台会将收到的设备消息转发到相应消费组，每条被流转到消费组的消息会被其中一个消费者接收。本文介绍如何在物联网平台创建、查看和...
用户文档
本文列出了Dubbo用户文档供您查阅。入门 背景 需求 架构 2.6.1 架构 2.7.1 用法 快速启动 依赖 成熟度 配置 XML配置 属性配置 API配置 注解配置 动态配置...2.7.x升级步骤及注意事项 Erlang语言 快速启动 消费者配置 提供者配置 序列化配置
同可用区优先路由
当应用服务开启同可用区优先后，消费者应用会优先调用同可用区的提供者，调用链路如下图所示：避免了跨可用区带来的网络延时，从而减少了HTTP的响应时间。如果当前可用区没有服务提供者时，服务调用者会调用到其他可用区的服务提供者。开启...
错误编码：HSF-0001
在服务消费者的配置项里添加 maxWaitTimeForCsAddress 的相关配置，请参见 开发服务消费者。本地开发环境排查 本地使用轻量配置中心进行开发时，服务发布、订阅均无需鉴权，故服务正常启动就可以注册、订阅成功。在排除掉前面的基本问题后...
查询HSF服务
您可以通过EDAS查询部署的HSF应用的服务列表和服务详情。查看服务列表 登录 EDAS控制台。在左侧导航栏选择 流量管理>...基本信息 服务调用关系 服务调用关系包含 服务提供者 和 服务消费者 列表及其 IP、端口、序列化方式 和 超时时间 信息。
商品管理
淘宝或天猫店铺中同步至LinkedMall品牌商城的优惠券、秒杀券、代金券、预售商品、仅限猫淘会员购买商品等活动类非常规商品需要商家手动下架（下架商品请参考 批量上架/下架），以免引起消费者无法下单、无法使用等问题。商品如参加天猫、...
跨账号网络实例授权
在网络实例下取消对企业版转发路由器实例的授权。具体操作，请参见 取消网络实例授权。在网络实例下重新为企业版转发路由器实例授权。具体操作，请参见 VPC实例授权、VBR实例授权、IPsec连接授权 和 ECR实例授权。授权过程中更改网络实例的...
API概览
UpdateConsumerOffset 重置消费者组的消费位点 通过 UpdateConsumerOffset 重置消费者组的消费位点。GetConsumerList 获取Consumer Group信息 调用GetConsumerList获取Group信息。GetConsumerProgress 查询消费组消费状态 查询Consumer ...
邮费购
商家也可以在分类页中提供一个分类（如：热门活动、0元付邮 等分类），方便消费者快速到达活动中的商品详情页，提升 访问-成交 转化率。添加活动 单击 添加活动，系统进入 添加活动 界面，根据界面要求填写完成后单击 保存 使配置生效。...
为什么消费位点过期了却仍未被删除？
说明 有任一存活的消费者线程的 Group 则是活跃 Group。例如，您创建了名为TestGroup的 Group 来订阅TopicA，并成功提交了消费位点。由于业务调整，您取消订阅TopicA，同时新订阅了TopicB。此时，TestGroup处于活跃状态，该 Group 在TopicA...
UpdateConsumerGroup-更新消费者组
在超时时间段内没有收到心跳，消费者将被删除。单位：秒。300 返回参数 名称 类型 描述 示例值 headers object Server string 服务器名称。nginx Content-Type string 响应内容类型。目前 Log Service 服务端响应类型支持 application/json...
预算管理
Hologres共享集群支持通过阿里云用户中心预算管理 和高额预警 功能对消费进行提醒，帮助您优化用云成本。本文为您介绍共享集群预算管理 和高额预警 的注意事项和使用说明。背景信息 不同于独享实例的包年包月和按量付费，共享集群提供了...
【升级公告】企业版转发路由器连接VPC模式升级
尊敬的阿里云用户，2022年05月31日云企业网对企业版转发路由器连接专有网络VPC（Virtual Private Cloud）的模式进行了优化升级，升级后的企业版转发路由器连接VPC实例后可以实现VPC流量的就近转发。升级内容 升级前，使用企业版转发路由器...
常见问题
为什么在控制台看不到消费者的客户端信息？为什么在控制台看不到Group的订阅关系？为什么消费位点过期了却仍未被删除？为什么同一个分区被多个消费线程消费了？为什么Group管理页面的Group变多了？为什么Group的状态一直处于“删除中”？为...
CreateConsumerGroup-创建消费组
在超时时间段内没有收到心跳，消费者将被删除。单位：秒。300 order boolean 是 是否按顺序消费。true：按顺序消费。同一个 Shard 内按照保留字段*_tag_:_receive_time_*由小到大按顺序消费。Shard 分裂后，先消费原 Shard 数据，然后同时...
变更消息配置
说明 只要Group内有任一存活的消费者线程，即使该Group下的消费位点超过了 消费位点保留时长，消费位点不会被删除。更多信息，请参见 为什么消费位点过期了却仍未被删除？ssl证书算法位数 实例开启公网时使用的SSL证书的算法位数。支持从...
- 产品推荐
- 这些文档可能帮助您