创建大会 一般由会务管理员或全局管理员创建，可在个人会务后台或在移动端“会务”应用中创建。 个人会务后台 登录个人会务后台，在首页单击“立即创建”。 设置主题名称，点击“确定”。 完成创建，进入大会列表界面。 移动端创建 登录移动端 WeLink ，在“业务”中找到“会务”或者在“数

查看更多 →

列表页面。 单击待查看消费者列表的消费组名称，进入消费组详情页。 在“消费者列表”页签，查看消费者列表。 在消费者列表中，可以查看消费者ID、消费者地址和客户端ID。 （可选）如果需要查询某个消费者，在搜索框中，输入消费者ID，按“Enter”。 查看消费者列表（客户端） 未开启

查看更多 →

分区数较多且每个消费者开启多个线程的情况下。 如图1所示，Topic含有多个分区，消费组中有多个消费者同时进行消费，每个线程均为长连接。当Topic中消息较少或者没有消息时，连接不断开，所有消费者不间断地拉取消息，这样造成了一定的资源浪费。 图1 Kafka消费者多线程消费模式 解决方案

查看更多 →

查询消费者列表 功能介绍 查询消费组内消费者列表 调用方法 请参见如何调用API。 URI GET /v2/rocketmq/{project_id}/instances/{instance_id}/groups/{group}/clients 表1 路径参数 参数 是否必选 参数类型

查看更多 →

放大会场画面-多流 接口名称 WEB_EnlargeMultiStreamSubPicAPI 功能描述 多流会议中，大画面显示某个会场图像。 应用场景 多流会议中，画廊视图模式下需要把某个会场全屏显示时使用该接口。 URL https://ip/action.cgi?Action

查看更多 →

配置RabbitMQ单一活跃消费者 单一活跃消费者（Single Active Consumer）表示队列中可以注册多个消费者，但是只允许一个消费者消费消息，只有在此消费者出现异常时，才会自动转移到另一个消费者进行消费。单一活跃消费者适用于需要保证消息消费顺序性，同时提供高可靠能力的场景。

查看更多 →

查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址，当客户端连接RocketMQ消费消息时，可通过控制台查看客户端的连接地址。 消费者处于连接RocketMQ实例时，才可以查看消费者连接地址。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。

查看更多 →

topics”的报错。 图1 消费者访问权限 处理方法： 如果业务要求所有消费者在同一个消费组内，即group.id相同，解决方法：为所有消费者授权相同的Topic访问权限。 如果消费者不需要在同一个消费组内，解决方法：修改group.id，让每个消费者单独在一个消费组内。 父主题：

查看更多 →

未发布的数据资产可以提供给数据消费者使用吗 未发布的数据资产不可以提供给数据消费者使用。基于数据安全要求（华为公司以及各国各地区的数据安全法规，比如欧盟GDPR）和公有云部署特点（数据上Internet没有网络隔离的情况），若要使用和消费数据，必须先对数据资产进行发布，再通过订阅数据资产来进行数据使用。

查看更多 →

实现RabbitMQ节点重启后消费者自动重连 方案概述 RabbitMQ的amqp-client虽然自带重连机制，但是自带的重连机制只会重试一次，重连失败后就不再执行。这时如果消费者没有做额外的重试机制，那么这个消费者就彻底断开与服务端的连接，无法消费消息。 amqp-clien

查看更多 →

Kakfa消费者读取单条记录过长问题 问题背景与现象 和“Kafka生产者写入单条记录过长问题”相对应的，在写入数据后，用户开发一个应用，以消费者调用新接口（org.apache.kafka.clients.consumer.*）到Kafka上读取数据，但读取失败，报异常大致如下：

查看更多 →

修改Kafka实例配置参数 分布式消息服务Kafka版为实例、Topic、消费者提供了几个常用配置参数的默认值，您可以根据实际业务需求，在控制台自行修改参数值。其他在控制台未列出的配置参数，请参考Kafka配置进行修改。 Kafka实例的参数分为动态参数和静态参数： 动态参数：动

查看更多 →

于数据消费者。 数据管理者可以对当前租户下治理的数据进行管理，例如：发布数据集、配置数据集授权、审批数据集订阅申请等，也可以对当前租户下发布的所有数据集和其他租户下发布的外部公开及已授权的秘密、机密或绝密的数据集进行消费，例如：订阅数据集、下载数据集到OBS桶等。数据消费者可以对

查看更多 →

于数据消费者。 数据管理者可以对当前租户下治理的数据进行管理，例如：发布数据集、配置数据集授权、审批数据集订阅申请等，也可以对当前租户下发布的所有数据集和其他租户下发布的外部公开及已授权的秘密、机密或绝密的数据集进行消费，例如：订阅数据集、下载数据集到OBS桶等。数据消费者可以对

查看更多 →

Kafka实例是否需要创建消费组、生产者和消费者？ “auto.create.groups.enable”为“true”时，不需要单独创建消费组、生产者和消费者，在使用时自动生成，实例创建后，直接使用即可。 “auto.create.groups.enable”为“false”时

查看更多 →

者端要做好消息的分类，便于消费者可以使用Tag进行消息的准确订阅。而在消费者端，则要保证订阅关系的一致性。 错误的订阅关系 同一消费组下的消费者订阅了不同的Topic 例如，消费组Group1下有消费者A和消费者B，消费者A订阅了Topic A，消费者B订阅了Topic B。当生产者向Topic

查看更多 →

生产者短时间内生产大量消息到Topic，消费者无法及时消费。 消费者的消费能力不足（消费者并发低、消息处理时间长），导致消费效率低于生产效率。 消费者异常（如消费者故障、消费者网络异常等）导致无法消费消息。 Topic分区设置不合理，或新增分区无消费者消费。 Topic频繁重平衡导致消费效率降低。

查看更多 →

生产者短时间内生产大量消息到Topic，消费者无法及时消费。 消费者的消费能力不足（消费者并发低、消息处理时间长），导致消费效率低于生产效率。 消费者异常（如消费者故障、消费者网络异常等）导致无法消费消息。 Topic分区设置不合理，或新增分区无消费者消费。 Topic频繁重平衡导致消费效率降低。

查看更多 →

预取值设置太大可能会导致从队列中取出大量消息传递给一个消费者，而使其他消费者处于空闲状态。另外还需要考虑消费者的配置，消费者在处理消息时会将所有消息保存在内存中，太大的预取值会对消费者的性能产生负面影响，甚至可能会导致消费者崩溃。 更多关于预取值的说明，请参考Consumer Prefetch。

查看更多 →

未发布的数据资产可以提供给数据消费者使用吗 未发布的数据资产不可以提供给数据消费者使用。基于数据安全要求（华为公司以及各国各地区的数据安全法规，比如欧盟GDPR）和公有云部署特点（数据上Internet没有网络隔离的情况），若要使用和消费数据，必须先对数据资产进行发布，再通过订阅数据资产来进行数据使用。

查看更多 →

正常情况下消费组内加入新的消费者或老的消费者退出都会导致Rebalance，这种情况是无法避免的。但是某些特殊情况下，消费者会被服务端认为异常从而被踢出消费组，此时可能会导致消费异常，需要重点关注。 消费者被服务端认为异常从而被踢出消费组的场景如下： 未能及时发送心跳请求。 消费者以设置的heartbeat

查看更多 →