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

查看更多 →

B，消费者A订阅了Tag A的消息，消费者B订阅了Tag B的消息。 如果消费者A和消费者B设置了相同的消费组，当生产者发送Tag A的消息时，Tag A的消息会均匀发送给消费者A和消费者B。由于消费者B没有订阅Tag A的消息，会把Tag A消息过滤掉，从而导致部分Tag A消息未被消费。 图1 错误的消费组设置

查看更多 →

费组中的所有消费者都无法进行正常的业务消费，该场景触发场景为消费组内有新的消费者加入或有已经建立连接的消费者退出。 STABILIZED：rebalance完成，消费组处于稳定状态，该状态下消费组中的消费者可以进行正常的业务消费，触发条件是，当前消费组内的所有消费者都同步完成新的

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？ 消息组中没有在线的消费者（如empty状态），14天后是否会自动被删除与offsets.retention.minutes、auto.create.groups.enable参数有关： 2023年4月25日前创建的实例，auto

查看更多 →

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

查看更多 →

配置技能组坐席。 管理员可以设置坐席最大会话数为0，设置为0后，坐席不会接入任何访客。 管理员和坐席都没有设置最大会话数，坐席可以处理最大会话数为在线-基本配置中坐席处理最大会话数；管理员或坐席设置最大会话数，以管理员或坐席设置的最新的最大会话数为主。 将“启用无障碍模式”的开关

查看更多 →

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

查看更多 →

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

查看更多 →

在 服务器 列表页面，查看服务器的会话数是否已达到最大会话数，如图1所示。 图1 比较服务器的会话数与最大会话数 服务器会话数已达到最大会话数，可参考管理服务器组增加服务器组的最大会话数，通知终端用户稍后重试。如果依然无法登录，请参考提交工单，填写工单信息，获取技术支持。 服务器会话数未达到最大会话数，请参考提交工单，填写工单信息，获取技术支持。

查看更多 →

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

查看更多 →

务端中就会存在两条内容相同的消息，最终消费者会消费到两条Message ID不同但内容相同的消息，因此造成了消息重复。 消费者消费消息时发生消息重复： 消费者消费消息时，服务端将消息投递至消费者并完成业务处理。如果此时发生网络闪断，导致消费者提交offset失败，服务端的offs

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →