comm_memory_pool_percent 参数说明：单个DN内通信库可使用内存池资源的百分比，用于自适应负载预留通信库通信消耗的内存大小。 参数类型：POSTMASTER 取值范围：整型，0~100 默认值：0 此参数需根据实际业务情况做调整，若通信库使用内存小，可设置该参数数值较小，反之设置数值较大。

查看更多 →

通信库参数 本节介绍通信库相关的参数设置及取值范围等内容。 tcp_keepalives_idle 参数说明：在支持TCP_KEEPIDLE套接字选项的系统上，设置发送活跃信号的间隔秒数。不设置发送保持活跃信号，连接就会处于闲置状态。 该参数属于USERSET类型参数，请参考表1中对应设置方法进行设置。

查看更多 →

过程中强制改为on。 取值范围：布尔型，CN设置为on表示使用TCP模式连接DN，DN设置为on表示DN间使用TCP代理通信。 默认值：on comm_sctp_port 参数说明：TCP代理通信库或SCTP通信库（由于规格变更，当前版本已经不再支持本特性，请不要使用）使用的TC

查看更多 →

购买Kafka实例 Kafka实例采用物理隔离的方式部署，租户独占Kafka实例。 创建Kafka Topic 创建用于存储消息的Topic，供生产者生产消息以及消费者订阅消息。 连接实例 客户端使用内网/公网通过命令行连接Kafka实例，并生产消费消息。 管理消息 在控制台查看消息。

查看更多 →

RocketMQ实例采用物理隔离的方式部署，租户独占RocketMQ实例。 创建RocketMQ Topic 创建用于存储消息的Topic，供生产者生产消息以及消费者订阅消息。 连接实例 客户端使用内网/公网通过命令行连接RocketMQ实例，并生产消费消息。 管理消息 在控制台查看消息。

查看更多 →

前的实时传输进度。 前置交换监控查询浏览 从前置区角度查看最近一次作业运行状态 从前置区角度查看文件传输实时进度 共享交换监控查询浏览 从共享区角度查看最近一次作业运行状态 从共享区角度查看文件传输实时进度 图1 交换监控 消费者监控 监控已经注册到系统当中的消费者提出的数据申请

查看更多 →

nkedIn开发。它是一个高吞吐量、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理 服务器 。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是Kafka集群中的核心组件，负责处理消息的存储和转发。K

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

消息通信相关问题 数据上报失败如何处理？ 若设备是使用接口注册的，请确认设备是否因为没在指定的timeout时间内上线而被物联网平台自动删除了。如果设备已被删除，请重新注册设备再尝试上报数据。 请检查使用接口注册设备时，填写的产品信息是否和产品模型一致。 请检查上报的数据名称是否和产品模型定义的服务属性一致。

查看更多 →

（例如当前偏移量已被删除）时，消费者的消费策略。取值如下： latest：偏移量自动被重置到最晚偏移量。 earliest：偏移量自动被重置到最早偏移量。 none：向消费者抛出异常。 如果将此配置设置为latest，新增分区时，生产者可能会在消费者重置初始偏移量之前开始向新增加的分区发送消息，从而导致部分消息丢失。

查看更多 →

附加到进程 您可以使用该启动配置将调试器附加到已运行的Python程序。 当您启动该配置时，CodeArts IDE会提示您选择要附加的进程。 启动配置属性 启动配置示例 父主题： 启动配置

查看更多 →

低选择杀不同优先级的进程。 策略 触发条件 清理进程 High档 总内存剩余25% 空进程 缓存进程 Middle档 总内存剩余20% 已使用过且不可感知类进程 （不可见、无悬浮窗、无音频焦点等） Low档 总内存剩余15% 上一个使用过的Activity进程 上一个使用过的Provider进程

查看更多 →

上传进程包 操作步骤 访问IoT边缘本地控制台。 选择左侧导航栏“应用管理 > 镜像仓库”进入页面，单击“上传进程包"。 图1 进程包列表 单击“添加文件”并选择需要上传的进程包。 图2 添加文件 父主题： 应用管理

查看更多 →

删除进程包 操作步骤 访问IoT边缘本地控制台。 选择左侧导航栏“应用管理 > 镜像仓库”进入页面。 图1 进程包列表 选择要删除的进程包，单击“删除”并确定。 图2 选择镜像名称 父主题： 应用管理

查看更多 →

后端写进程 介绍后端写（background writer）进程的参数配置。后端写进程的功能就是把共享缓冲区中的脏数据（指共享缓冲区中新增或者修改的内容）写入到磁盘。目的是让数据库进程在进行用户查询时可以很少或者几乎不等待写动作的发生（写动作由后端写进程完成）。 此机制同样也减少

查看更多 →

创建Kafka Topic Topic，即消息主题，用于存储消息，供生产者生产消息以及消费者订阅消息。创建Kafka实例成功后，如果没有开启“Kafka自动创建Topic”，需要手动创建Topic。如果实例开启了“Kafka自动创建Topic”，则该操作为可选。 “Kafka自动

查看更多 →

CreateTime：生产者创建消息的时间。 LogAppendTime：broker将消息写入日志的时间。 批处理消息最大值 Kafka允许的最大批处理大小，如果启用消息压缩，则表示压缩后的最大批处理大小。 如果增加“批处理消息最大值”的值，且存在消费者版本早于0.10.2，此时消费者的“fetch

查看更多 →

守护进程集 创建守护进程集 （可选）若基于我的镜像创建工作负载，用户首先需要将镜像上传至 容器镜像服务 ，上传镜像的方式请参见镜像管理。若基于开源镜像中心创建工作负载，则无需上传镜像。 在集群控制台选择“工作负载 > 守护进程集”，单击“镜像创建”。 参照表1设置基本信息，其中带“*”标志的参数为必填参数。

查看更多 →