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

查看更多 →

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

查看更多 →

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

查看更多 →

当数据集的密级等级是秘密、机密或绝密时，只有被授权的数据消费者和发布该数据集所在租户下的数据管理者和消费者有权限订阅该数据集。如果发布该数据集时已设置“本租户内是否免审批”为“否”，则只有发布该数据集所在租户下的“Data Owner”角色用户可以立即订阅该数据集，被授权的数据消费者和发布该数据集所在租户下的“Data

查看更多 →

生产耗时 生产者发送消息的耗时。 地址 生产者的IP地址。 消费者状态 消费者状态如下： 消费成功 消费超时 消费异常 消费返回NULL 消费失败 消费时间 消费消息的时间。 消费耗时 消费者消费消息的耗时。 地址 消费者的IP地址。 父主题： 管理消息

查看更多 →

WeLink 会议参加会议人数有什么限制？ 为提升大会场情景下会议质量，WeLink云会议采用分布式部署，遍布多个地区的 服务器 群组，保障超大会议规格、充沛的会议资源，目前限制情况及能力如下： 最大支持1000方双向视频会议 24小时超长会议时长 可提前1年预约会议 父主题： 产品规格

查看更多 →

会务管理员 可以使用会务应用，创建大会，可以使用会务个人后台。 需要辅助组织会务的人员。一般为公司行政、秘书等会务组织者。 会务组成员 可以使用会务应用，编辑某个大会内容，可以使用会务个人后台。 参加会议的人。 与会者 享受会务通带来的会务服务。 申请权限 创建大会 人员管理 创建IM互动群

查看更多 →

--add --allow-principal User:用户名 --consumer --topic 主题名称 --group 消费者组名称 删除某个用户的消费者权限 sh kafka-acls.sh --authorizer-properties zookeeper.connect=

查看更多 →

是否设置为广播消费。 若开启广播消费，每条消息都会被消费组内的所有消费者消费一次。否则，每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5.x时，需要设置此参数。 开启顺序消费后，消费者将顺序消费消息。 描述 消费组的描述信息。 修改完成后，单击“确定”。

查看更多 →

producer = new TransactionMQProducer("ProducerGroupName", rpcHook); 消费者增加用户认证信息 在消费者客户端新建配置文件“config.yaml”，添加如下认证信息。如果配置文件已存在，无需再次创建，直接添加认证信息。 ACL_ACCESS_KEY:

查看更多 →

导出数据 导出大会列表 会务应用管理员和全局管理员可进入会务通管理后台，查看并导出大会活动列表。 导出签到人员名单 会务管理员可在个人会务后台导出现场签到抽奖人员。 勾选未签到人员，单击“替TA签到”，可帮TA签到；单击“添加嘉宾”，可手动添加签到人员；单击“导出”，可导出人员信

查看更多 →

生产者向消息主题发布消息，多个消费者订阅该消息主题的消息，生产者与消费者彼此并无直接关系。 生产者（Producer） 向Topic（消息主题）发布消息的一方。发布消息的最终目的在于将消息内容传递给其他系统/模块，使对方按照约定处理该消息。 消费者（Consumer） 从Topi

查看更多 →

本小节介绍如何在开发者本地进行消费者/提供者应用的开发调试。服务提供者和消费者均需要连接到在远程的服务中心，为了本地微服务的开发和调试，本小节介绍了如何启动本地服务中心。 服务中心是微服务框架中的重要组件，用于服务元数据以及服务实例元数据的管理和处理注册、发现。服务中心与微服务提供/消费者的逻辑关系下图所示：

查看更多 →

常见问题 数据集有哪些密级 数据管理者与数据消费者的区别是什么 未发布的数据资产可以提供给数据消费者使用吗 如何发布数据集 如何订阅数据集 如何下载数据集 数据集下载成功后有哪些使用方式 修订记录

查看更多 →

消费组问题 Kafka实例是否需要创建消费组、生产者和消费者？ 如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？ 客户端删除消费组后，在Kafka Manager中仍可以看到此消费组？

查看更多 →

基本概念 帐号分类 个人华为帐号：是由个人在华为集团帐号系统申请获得，包括使用终端设备、华为云渠道、消费者应用等获取。该类帐号归属于个人，可以通过邀请方式加入组织，也可以自己开通OrgID并创建组织。 管理式华为帐号：是由组织的管理员创建生成，该类帐号只归属于本组织所有，不可以加入其他组织。

查看更多 →

静态目标服务 方案介绍 通过dubbo:reference在Dubbo服务的服务消费者中对引用的服务提供者进行配置。使用选项url定义点对点直连服务提供者地址，绕过注册中心，直接调用目标服务。 详细说明 如果原Dubbo服务中使用的是xml配置文件，则只需要修改配置文件即可。 <

查看更多 →

HBase占用网络端口，连接数过大会导致其他服务不稳定 问题 HBase占用网络端口，连接数过大会导致其他服务不稳定。 回答 使用操作系统命令lsof或者netstat发现大量TCP连接处于CLOSE_WAIT状态，且连接持有者为HBase RegionServer，可能导致网络

查看更多 →

HBase占用网络端口，连接数过大会导致其他服务不稳定 问题 HBase占用网络端口，连接数过大会导致其他服务不稳定。 回答 使用操作系统命令lsof或者netstat发现大量TCP连接处于CLOSE_WAIT状态，且连接持有者为HBase RegionServer，可能导致网络

查看更多 →

数据集 数据集有哪些密级 数据管理者与数据消费者的区别是什么 未发布的数据资产可以提供给数据消费者使用吗 如何发布数据集 如何订阅数据集 如何下载数据集 数据集下载成功后有哪些使用方式 父主题： 常见问题

查看更多 →

定时间后才会发送给消费者进行消费。 顺序消息：消费者按照消息发送的顺序来消费消息。 事务消息：提供类似X/Open XA的分布事务功能，通过事务消息能达到分布式事务的最终一致。 支持的高级特性 分布式消息服务RocketMQ版支持4种高级特性。 消息过滤：消费者根据分布式消息服务

查看更多 →