Kafka Client 功能 通过Kafka Client向Kafka的Topic中发送数据。 您可以参考跨空间进行作业调度，获取Kafka Client节点的使用案例。 参数 用户可参考表1配置Kafka Client节点的参数。 表1 属性参数 参数 是否必选 说明 数据连接

查看更多 →

任务增量步进，与memoryStep共同决定内存调整量 不能为空且大于零 memoryStep 内存增量步进，在"yarn.app.mapreduce.am.resource.mb"配置的基础上对内存向上调整 不能为空且大于零，单位：MB minMemory 内存自动调整下限，若调整后的内存不大于该值，仍保持"yarn

查看更多 →

任务增量步进，与memoryStep共同决定内存调整量 不能为空且大于零 memoryStep 内存增量步进，在"yarn.app.mapreduce.am.resource.mb"配置的基础上对内存向上调整 不能为空且大于零，单位：MB minMemory 内存自动调整下限，如果调整后的内存不大于该值，仍保持"yarn

查看更多 →

JVM监控界面内存监控中，为何最大内存比分配内存小？ 通过-Xmx设置了堆内存的最大值，堆内存的分配值也不一定比设定的堆内存的最大值小，JVM是动态申请堆内存的，即使配置了-Xms最小值，也不是一开始就分配到-Xms值，会根据2的倍数申请，很可能稍微超过-Xmx的限制，可增加-X

查看更多 →

Kafka客户端使用建议 consumer使用建议 consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 通常不建议对每条消息都进行commit，如果对

查看更多 →

Consumer使用建议 Consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 Consumer不能频繁加入和退出group，频繁加入和退出，会导致Con

查看更多 →

执行以下命令切换到Kafka客户端安装目录。 cd Kafka/kafka/bin 执行以下命令使用客户端工具查看帮助并使用。 ./kafka-console-consumer.sh：Kafka消息读取工具 ./kafka-console-producer.sh：Kafka消息发布工具

查看更多 →

Kafka客户端参数配置建议 Kafka客户端的配置参数很多，以下提供Producer和Consumer几个常用参数配置。不同版本的Kafka客户端参数名称可能不同，以下配置参数适用于1.1.0及以上版本。其他参数和版本配置，请参考Kafka配置。 表1 Producer参数 参数

查看更多 →

通道分配 MQTT类型通道分配至节点 IoTDB类型通道分配至节点 InfluxDB V2类型通道分配至节点 父主题： 路由转发

查看更多 →

单击租户名称右侧的“分配”，弹出“分配资源”对话框，如图3所示。 用户需要参考表1进行配置，如果需要分配多种资源类型，可单击右侧的图标，新增资源行。 图3 分配资源 表1 参数说明 参数 说明 请选择资源类型 从下拉框中选择已购买的资源类型。 示例：分身数字人形象制作。 请选择资源实例 从下拉框中选择已购买的资源实例。

查看更多 →

执行以下命令切换到Kafka客户端安装目录。 cd Kafka/kafka/bin 执行以下命令使用客户端工具查看帮助并使用。 ./kafka-console-consumer.sh：Kafka消息读取工具 ./kafka-console-producer.sh：Kafka消息发布工具

查看更多 →

DIS Client 功能 通过DIS Client节点可以给DIS通道发送消息。 您可以参考跨空间进行作业调度，获取DIS Client节点的使用案例。 参数 用户可参考表1配置DIS Client节点的参数。 表1 属性参数 参数 是否必选 说明 节点名称 是 节点名称，可以

查看更多 →

资源成本：各类资源的成本，这取决于分布式消息服务Kafka版的计费项，详细介绍请参见计费项。 运维成本：使用分布式消息服务Kafka版过程中产生的人力成本。 图1 Kafka成本 华为云成本中心可以帮助您更高效地管理资源成本，但运维成本需要您自行识别、管理和优化。 成本分配 成本管理的基础是树

查看更多 →

True 工单的责任人，工单自动分配时可以不填写，创建工单接口中根据分配逻辑自动分配责任人 3 creatorId string 20 True 操作处理人id 如果分配工单涉及的工单类别使用了自定义的工单模板，则工单模板上扩展的字段可继续在请求消息体中继续往后添加。 响应说明 响应状态码:

查看更多 →

执行以下命令，切换到客户端目录，例如“/opt/client/Kafka/kafka/bin”。 cd /opt/client/Kafka/kafka/bin 执行以下命令，配置环境变量。 source /opt/client/bigdata_env 执行以下命令，进行用户认证。（普通模式跳过此步骤）

查看更多 →

如何避免上传重复文件？ 视频点播服务提供了上传校验功能。在控制台上传音视频文件时，打开“防止上传重复文件”开关，即会对添加的音视频文件进行校验，检查点播服务中是否已存在内容相关的文件。 图1 本地上传 您也可以使用点播服务提供的上传检验接口进行重复文件检查。 父主题： 上传问题

查看更多 →

level1：动态内存使用超过最大动态内存的90%后，会记录以下信息，并将记录的内存信息保存在$GAUSS LOG /mem_log目录下。 全局内存概况。 instance，session，thread三种类型的所有内存上下文中内存占用前20的内存上下文的内存使用情况。 每个内存上下文的totalsize、freesize字段。

查看更多 →

8MB（196核CPU/1536G内存，128核CPU/1024G内存，104核CPU/1024G内存，96核CPU/1024G内存，96核CPU/768G内存，80核CPU/640G内存，64核CPU/512G内存，60核CPU/480G内存，32核CPU/256G内存，16核CPU/128G内存，8核C

查看更多 →

Rest Client 功能 通过Rest Client节点执行一个华为云内的RESTful请求。 Rest Client算子的具体使用教程，请参见获取Rest Client算子返回值教程。 当由于网络限制，Rest Client某些API无法调通时，可以尝试使用Shell脚本进

查看更多 →

如何避免频繁登录CodeArts？ CodeArts采用华为云统一的会话超时策略，会话超时时长默认为1个小时。 当用户超过设置的时长未操作界面，会话将会失效，需要重新登录。 管理员可以通过统一身份认证服务（IAM）的“安全设置”页面设置会话超时策略。 登录华为云控制台，鼠标移动至

查看更多 →

）。 已安装Kafka客户端。 Kafka实例状态和磁盘状态均正常。 根据待迁移分区当前的磁盘空间占用情况，评估迁移后，不会导致新迁移后的磁盘空间不足。 使用Kafka客户端迁移数据 以客户端安装用户，登录已安装Kafka客户端的节点。 执行以下命令，切换到Kafka客户端安装目

查看更多 →