的原因。 镜像队列主要的缺陷在于消息同步的性能低。 镜像队列包含一个主队列和多个从队列，当生产者向主队列发送一条消息，主队列会将消息同步给从队列，所有的从队列都保存消息后，主队列才会向生产者发送确认。 RabbitMQ使用集群部署时，如果其中一个节点故障下线，待它消除故障重新上线

查看更多 →

息更新时间。 图2 分区信息 生产者信息：包含Broker地址、生产者地址和加入时间。 仅当生产者正在往Topic中生产消息时，才显示生产者信息。 2023年7月10日以及之前创建的Topic，在Topic详情页面不显示“生产者”页签。 图3 生产者信息 父主题： Topic管理

查看更多 →

afka> --topic <Topic名称> --from-beginning Producer API生产消息，需要拥有该Topic生产者权限。 sh kafka-console-producer.sh --broker-list <Kafka集群IP:21007> --topic

查看更多 →

producerThread = new Producer(KafkaProperties.TOPIC, asyncEnable); } Kafka生产者代码可参考使用Producer API向安全Topic生产消息。 KafkaConsumerMultThread.java： 该样例展示如

查看更多 →

app-name需要同时配置。 connector. checkpoint-app-name 否 DIS服务的消费者标识，当不同作业消费相同通道时，需要区分不同的消费者标识，以免checkpoint混淆。 勿与offset或start-time同时设置；若enable-checkpoint为true，则需要同时配置。

查看更多 →

程和人员等各种能力整合到一起的一种协同工作方式。 生产者 是用来构建并传输数据到服务端的逻辑概念，负责把数据放入消息队列。 订阅器 用于订阅安全云脑管道消息，一个管道可由多个订阅器进行订阅，安全云脑通过订阅器进行消息分发。 消费者 是用来接收并处理数据的运行实体，负责通过订阅器把安全云脑管道中的消息进行消费并处理。

查看更多 →

MB/s（计算方法：所属Topic的数据流量除以Partition数） 、数据保存时间为T(Pm)小时，那么单个磁盘必须满足： 根据吞吐量粗略计算，假设生产者可以达到的吞吐量为P，消费者可以达到的吞吐量为C，预期Kafka吞吐量为T，那么建议该Topic的Partition数目设置为Max(T/P , T/C)。

查看更多 →

MB/s（计算方法：所属Topic的数据流量除以Partition数） 、数据保存时间为T(Pm)小时，那么单个磁盘必须满足： 根据吞吐量粗略计算，假设生产者可以达到的吞吐量为P，消费者可以达到的吞吐量为C，预期Kafka吞吐量为T，那么建议该Topic的Partition数目设置为Max(T/P , T/C)。

查看更多 →

app-name需要同时配置。 connector. checkpoint-app-name 否 DIS服务的消费者标识，当不同作业消费相同通道时，需要区分不同的消费者标识，以免checkpoint混淆。 勿与offset或start-time同时设置；若enable-checkpoint为true，则需要同时配置。

查看更多 →

添加其他Vhost信息。 图1 创建用户 单击“确定”，完成用户的创建。 步骤三：通过用户访问服务端 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息（代码中需包含username和password），具体操作如下： Java代码示例 Python代码示例 父主题：

查看更多 →

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

查看更多 →

使用ACL权限访问 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 生产者增加用户认证信息 普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 import ( "context" "fmt" "os"

查看更多 →

DIS对于从数据生产者快速移出数据，然后进行持续处理非常有用。以下是使用DIS的典型场景： 加速日志和数据传送获取：您无需等待批量处理数据，而是让数据生产者在生成数据后立即输入DIS数据通道，防止因数据生产者出现故障导致的数据损失。例如，系统和应用程序日志可以持续添加到数据通道并可在数秒内进行处理。

查看更多 →

分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。同时也支持定时消息的取消。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。

查看更多 →

earliest：自动复位offset为最早 latest：自动复位offset为最新 none：如果没有发现offset则向消费者抛出异常 anything else：向消费者抛出异常。 connections.max.idle.ms 600000 30000 空连接的超时时间，设置为30

查看更多 →

以clientId为维度统计消息推送详情） clientId clientId 客户端实例标识 - ENUM LAST group 生产者组 生产者组 - ENUM LAST pid pid pid - STRING LAST concurrentMax 最大并发 推送消息最大并发

查看更多 →

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

查看更多 →

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

查看更多 →

分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。同时也支持定时消息的取消。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5

查看更多 →

行在不同的Vhost上，相互之间不会干扰。一个实例下可以有多个Vhost，一个Vhost里可以有若干个Exchange和Queue。生产者和消费者连接RabbitMQ实例时，需要指定一个Vhost。Vhost的相关介绍，请参考官网文档Virtual Hosts。 本章节主要介绍创

查看更多 →

费实时性要求较高的业务系统，即使是消息堆积造成的短暂消息延迟也无法接受。造成消息堆积的原因有以下两个： 消息没有及时被消费，生产者生产消息的速度快于消费者消费消息的速度，从而产生消息积压且无法自行恢复。 业务系统本身逻辑耗费时间较长，导致消息消费效率较低。 消息消费过程 一个完整的消息消费过程主要分为2个阶段：

查看更多 →