据集并下载到OBS桶。 秘密、机密或绝密的数据集需要在发布时或发布成功后配置授权给数据消费者，否则，数据消费者无权限查看和订阅该数据集并下载到OBS桶，发布该数据集所在租户下的数据管理者和消费者可以查看和订阅该租户下发布的数据集并下载到OBS桶，无需授权。秘密、机密或绝密的数据集

查看更多 →

理该消息。 消费者（Consumer） 接收消息的一方。消费者订阅RabbitMQ的队列，当消费者消费一条消息时，只是消费消息的消息体。在消息路由的过程中，会丢弃标签，存入到队列中的只有消息体。 队列（Queue） 队列是用于存储消息的，生产者将消息送到队列，消费者从队列中获取和

查看更多 →

once，就必须使用同步等待方式。 消费者确认 消费者确认是指服务端通过确认消息是否成功被消费者接收，来判断是否删除队列中的此消息。 消费者确认对数据可靠性十分重要，接收重要消息的消费应用程序在未处理完消息前不应确认消息，以便消费者有足够的时间处理消息，无需担心消息处理过程中由于消费者进程异常（如工作程序崩溃、重启等）导致消息丢失。

查看更多 →

服务控制 系统调用关系管 消费者访问数据服务共享平台中web服务共享资源，数据管理员给消费者分配web服务的访问权限。其主要功能包括： 支持web服务调用关系管理； 支持Server端调用关系控制处理； 支持Server端调用关系控制告警信息处理； 支持消费者与Web服务调用关系控制关系配置。

查看更多 →

势的影响，全方位了解智慧家庭、园区及城市行业发展趋势与典型应用场景。 培训内容 培训内容 说明 物联网的前世今生 物联网概念，发展趋势，AIoT的概念与发展，物联网对政府和企业的重要性 物联网技术与架构 物联网分层架构，物联网与5G，物联网平台及操作系统 物联网应用案例 智慧家庭，智慧园区，智慧城市

查看更多 →

ange、队列、生产者数量、消费者数量、实例规格，开启SSL和未开启SSL的实例 测试场景三（生产者/消费者数量）：相同Exchange、队列、实例规格，不同数量的生产者和消费者 测试场景四（单队列和多队列）：相同Exchange、生产者数量、消费者数量、实例规格，不同的队列数量

查看更多 →

消费端处理，这样队列中就会产生大量的消息堆积。 消费者出现异常，生产者一直在发送消息，但是消费者不能消费，造成消息积压。 消费者没有出现异常，但是消费者与队列间的订阅可能出现了异常，也会导致消息无法被消费从而造成堆积的情况。 消费者正常，与队列间的订阅也正常，但是消费端的代码本身

查看更多 →

送成功后，在服务端中就会存在两条内容相同的消息，最终消费者会消费到两条内容一样的重复消息。 消费者消费消息时发生消息重复： 消费者消费消息时，服务端将消息投递至消费者并完成业务处理。如果此时发生网络闪断，导致服务端未收到消费者的响应，此时服务端会认为消息投递失败。为了保证消息至少

查看更多 →

为目标RabbitMQ实例添加新的消费者，准备消费目标实例的消息。 图4 添加新消费者 为目标RabbitMQ实例添加新的生产者，下线原RabbitMQ实例的生产者，旧的消费者继续消费原RabbitMQ实例中的消息。 图5 迁移生产者 旧的消费者消费完原RabbitMQ实例的全部消息后，下线旧的消费者和原RabbitMQ实例。

查看更多 →

XDEL key ID [ID ...] XGROUP 该命令用于管理流数据结构关联的消费者组。使用XGROUP你可以： 创建与流关联的新消费者组。 销毁一个消费者组。 从消费者组中移除指定的消费者。 将消费者组的最后交付ID设置为其他内容。 XGROUP [CREATE key groupname

查看更多 →

Kafka应用开发建议 同一个组的消费者的数量建议与待消费的Topic下的Partition数保持一致 若同一个组的消费者数量多于Topic的Partition数时，会有多余的消费者一直无法消费该Topic的消息，若消费者数量少于Topic的Partition数时，并发消费得不到完全体现，因此建议两者相等。

查看更多 →

消费组问题 Kafka实例是否需要创建消费组、生产者和消费者？ 如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？ 为什么删除消费组不生效？ 实例消费正常，为什么看不到消费者？ Kafka可以删除消费组下不用的Topic吗？

查看更多 →

向Kafka的主题发布消息。 Consumer/消费者 向Topic订阅，并且接收发布到这些Topic的消息。 各模块间关系如图2所示。 图2 Kafka模块间关系 消费者使用一个消费者组名称来标记自己，主题的每个消息被传递给每个订阅消费者组中的一个消费者。如果所有的消费者实例都属于同样的消费组，它们

查看更多 →

取值范围：1～16 如果是顺序消费，可通过消费者的setMaxReconsumeTimes函数配置。 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费，每条消息都会被消费组内的所有消费者消费一次。否则，每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5

查看更多 →

同一类生产者的集合，这类生产者发送同一类消息且发送逻辑一致。 消费者（Consumer） 接收消息的对象，负责从服务端获取消息。 消费组（Consumer Group） 多个消费者组成同一个消费组，同一消费组内的消费者具有相同的消费属性。 代理（Broker） 一组节点构成的一个业务集群。

查看更多 →

统计周期内，已经成功对接的数量，即消费者与供应商之间的联系数量。 所属集群分布 统计周期内，成功对接的集群分布，即哪些集群的消费者和供应商已经建立了联系。 所属行业分布 统计周期内，成功对接的行业分布，即哪些行业的消费者和供应商已经建立了联系。 需求总数 统计周期内，市场需求的总量，即消费者对产品或服务的需求量。

查看更多 →

一个或多个Queue中，生产者生产消息并最终投递到Queue中，消费者可以从Queue中拉取消息进行消费。 多个消费者可以订阅同一个Queue，此时Queue中的消息会被平均分摊给多个消费者进行处理，而不是每个消费者都收到所有的消息。 本章节指导如何在控制台创建Queue。 前提条件

查看更多 →

同一个客户端可以作为生产者生产消息，也可以作为消费者消费消息，连接IP地址是相同的，如图1所示，此时我们无法区分哪个是生产者IP地址，哪个是消费者IP地址。如果想要直观体现生产者/消费者IP地址，您可以在客户端中设置“clientProperties”参数，通过此参数来标明生产者/消费者IP地址，示例如下。

查看更多 →

l Warehouse，以下简称VW）之间建立KV订阅关系，建立了订阅关系之后，消费者VW的KVcahce会定期的从生产者的obs cudesc快照目录增量同步sst文件到本地，后续就可以支持在消费者VM中跨VW查询生产者VW中的表。 创建的订阅关系可以在pgxc_group_s

查看更多 →

数据使用 消费方注册 消费者可通过系统管理员进行账号的创建和权限分配。主要功能包括： 基本信息维护； 密码初始化、修改； 消费者权限分配。 图1 消费方注册 数据服务使用 数据资源申请 消费方通过资源申请方式申请主题分类资源树中的数据实体资源，相对平台而言“拉”的方式，消费方申请

查看更多 →

Rebalance是重新分配消息组中的消费者和Topic分区之间订阅关系的过程。在Rebalance过程中消费组下的所有消费者都会停止消费，等待Rebalance完成。 可能会触发Rebalance的原因： 消费组成员个数发生变化，例如有新的消费者加入，或者有消费者退出。 消费组订阅的Topic个数发生变化。

查看更多 →