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

查看更多 →

，该如何选择服务范围？ 业务集中在一个城市，是否有必要使用CDN？ 华为云CDN如何判断用户所属地区？ 从其它服务商迁移CDN到华为云要怎么做？CDN如何切流？ 使用华为云CDN，是否必须在华为云备案？ 同一个加速 域名 是否可以加速多个源站域名？ 配置CDN后能否加速文件上传速度？

查看更多 →

的用户特征画像，最大化地利用广告平台，实现精准的定向广告投放，提高转化率。 其业务场景可简要分为以下几个步骤： 大数据平台根据自身分析数据及对接的多个第三方数据服务商进行综合建模，匹配每个活跃用户的多维度模型，分析得到目标用户的高精细融合特征数据画像，并将海量特征画像数据存入云数据库

查看更多 →

租户或用户到可视范围，用于将数据集授权给数据消费者（这里的数据消费者为其他租户下的数据消费者和数据管理者，下文中相同），被授权的数据消费者在数据集发布成功后可以查看和订阅该数据集并下载到OBS桶。发布数据集所在租户下的数据管理者和消费者可以查看和订阅该租户下发布的数据集并下载到OBS桶，无需授权。

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

评估项目概述 评估项目的创建是连接源库进行基本信息采集、性能数据采集，以及特定对象类型的源库对象SQL采集，基于采集的数据进行源库画像、数据库特性分析、到各个目标数据库的语法兼容性评估。综合兼容性、性能、对象复杂度、使用场景等为用户智能化推荐目标数据库选型与规格，工作量评估以及迁移风险评估，帮助用户决策与工作规划。

查看更多 →

创建Kafka消费组 消费者是从Topic订阅消息的一方，消费组是由一个或多个消费者组成的。同一个消费组内，一个消费者可同时消费多个分区，但一个分区在同一时刻只能被一个消费者消费。 图1 消费关系示例图 “auto.create.groups.enable”表示在消费者进入未创建的消费组时，会自动创建此消费组。

查看更多 →

参数类型 说明 作业ID(job_id) 是 String 作业的ID。离线策略特征工程-初始用户画像-物品画像-标准宽表算子、近线策略基于用户数据更新用户画像算子、近线策略基于物品数据更新物品画像算子可以作为此处的作业ID。 新的全局特征配置文件路径(new_global_features_info)

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

提交成功：允许消费者消费此事务消息。 回滚：事务消息将被丢弃，不允许消费者消费此事务消息。 未知，待确认：事务消息状态暂时无法确定，等待固定时间后，服务端向生产者进行消息回查。 生产耗时 生产者发送消息的耗时。 单位：毫秒 生产地址 生产者的IP地址。 消费者状态 消费者状态如下： 消费成功

查看更多 →

附录：如何提高消息处理效率 消息生产和消费的可靠性必须由ROMA Connect、生产者和消费者协同工作才能保证，对使用ROMA Connect的生产者和消费者有如下的使用建议。 重视消息生产与消费的确认过程 消息生产 生产消息后，生产者需要根据ROMA Connect的返回信息

查看更多 →

消息发送和消费的可靠性必须由分布式消息服务Kafka版和生产者以及消费者协同工作才能保证。同时开发者需要尽量合理使用分布式消息服务Kafka版的Topic，以提高消息发送和消息消费的效率与准确性。 对使用分布式消息服务Kafka版的生产者和消费者有如下的使用建议： 重视消息生产与消费的确认过程 消息生产

查看更多 →

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

查看更多 →

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

查看更多 →

据。 用户数据 用户数据包括数据源中的“用户属性表”和用于近线计算的“用户画像”数据。用户数据记录用户的属性信息，例如地域、爱好等。 物品数据 物品数据包括数据源中的“物品属性表”和用于近线计算的“物品画像”数据。物品数据记录物品的属性信息，例如类别、长度等。 行为数据 行为数据

查看更多 →

使用统计信息，还支持查看所有推流域名的转码时长、录制最大并发数和截图数量统计信息。 业务监控：支持查看播放域名的下行带宽/流量使用量、播放画像信息、请求响应返回的所有状态码及对应直播流的在线观看人数等数据，还支持查看对应推流域名的上行带宽/流量使用量、总推流路数及推流帧率/码率等监控信息。

查看更多 →

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

查看更多 →