Kafka客户端角色包括Producer和Consumer两个角色，其应用开发流程是相同的。 开发流程中各个阶段的说明如图1和表1所示。 图1 Kafka客户端程序开发流程 表1 Kafka客户端程序开发的流程说明 阶段 说明 参考文档 了解基本概念 在开始开发客户端前，需要了解Kafka的基本概念，根据实际场景判断

查看更多 →

启动 服务器 、集群检查与注意事项 启动服务器 集群配置文件完成后，先启动server1，待server1启动完成后，可同时启动其它三个服务器。 集群检查 以admin身份登录睿码平台，依次进入“系统设置 > 性能与维护 > 集群信息”，检查如下信息： 检查所有配置节点是否存在 检查所有节点在线状态

查看更多 →

提供了Producer和Consumer相关API的使用样例，包含了API和多线程的使用场景，帮助用户快速熟悉Kafka接口。 开发Kafka应用 编译与运行程序 指导用户将开发好的程序编译并提交运行。 调测Kafka应用 父主题： Kafka开发指南（普通模式）

查看更多 →

环境准备。 准备运行调测环境 在弹性云服务器管理控制台，申请一个新的弹性云服务器，用于应用开发运行调测。 弹性云服务器的安全组需要和 MRS 集群Master节点的安全组相同。 弹性云服务器的VPC需要与MRS集群在同一个VPC中。 弹性云服务器的网卡需要与MRS集群在同一个网段中。

查看更多 →

操作流程（服务器上架与服务启动） 3.1产品使用前准备 设备安装上架 设备加电自检 设备硬件管理 设备系统管理

查看更多 →

' 出于安全考虑，建议使用源端服务器的WinRMhost（即主机名或IP地址）替换TrustedHosts 的值"*"。不替换代表信任任意主机。 测试远程连接。 使用以下命令测试与源端服务器的连接，“登录账号”和“源端服务器IP”需要替换为源端服务器实际的登录账号和IP地址。 Enter-PSSession

查看更多 →

将开发好的程序编译运行，用户可在本地Windows开发环境中进行程序调测运行，也可以将程序编译为Jar包后，提交到Linux节点上运行。 开发Kafka应用 编译与运行程序 指导用户将开发好的程序编译并提交运行并查看结果。 调测Kafka应用 父主题： Kafka开发指南（安全模式）

查看更多 →

Loader与其他组件的关系 与Loader有交互关系的组件有HDFS、HBase、Hive、Yarn、Mapreduce和ZooKeeper等。 Loader作为客户端使用这些组件的某些功能，如存储数据到HDFS和HBase，从HDFS和HBase表读数据，同时Loader本身

查看更多 →

Authentication）方式访问 FusionInsight Manager REST API的用户使用。 REST API REST API是访问Web服务器的一套API，REST API接口的执行方式是通过HTTP请求进行的，接收GET、PUT、POST、DELETE等请求并使用JSON数据进行响应。

查看更多 →

分桶表不支持insert into 分桶表（bucket table）不支持insert into，仅支持insert overwrite，否则会导致文件个数与桶数不一致。 使用WebHCat的部分REST接口的前置条件 WebHCat的部分REST接口使用依赖于MapReduce的JobHistoryServer实例，具体接口如下：

查看更多 →

准备一个应用程序运行测试的Linux环境。 准备运行调测环境 在弹性云服务器管理控制台，申请一个新的弹性云服务器，用于用户应用程序开发、运行、调测。 弹性云服务器的安全组需要和MRS集群Master节点的安全组相同。 弹性云服务器的VPC需要与MRS集群在同一个VPC中。 弹性云服务器的网卡需要与MRS集群在同一个网段中。

查看更多 →

autoDelete表示是否自动删除，true表示自动删除。自动删除的前提是至少有一个队列或者交换器与该交换器绑定，之后所有与该交换器绑定的队列或者交换器都会解绑。 internal表示是否为内置交换器，true表示是内置的交换器。客户端程序无法直接发送消息到这个交换器，只能通过交换器路由到这个交换器。 arguments表示其他属性。

查看更多 →

专属主机与普通 云服务器 的区别？ 专属主机是部署了虚拟化环境的专属物理服务器，用户独享整台物理服务器资源，与其他租户的服务器物理隔离。用户申请后，可以在专属主机上创建虚拟机，支持用户自主规划物理服务器资源。 普通云服务器是多个租户共享物理服务器资源。 父主题： 专属主机类

查看更多 →

在Linux上安装客户端。 操作步骤 客户端机器的时间与Hadoop集群的时间要保持一致(手动修改客户端机器或者集群的时间)，时间差小于5分钟。 MRS集群的时间可通过登录主管理节点（集群管理IP地址所在节点）运行date命令查询。 下载MapReduce客户端程序到客户端机器中。 登录MRS Manager系统。

查看更多 →

客户端运行环境已安装1.7或1.8版本的JDK。 客户端机器的时间与Hadoop集群的时间要保持一致，时间差小于5分钟。 MRS集群的时间可通过登录主管理节点（集群管理IP地址所在节点）运行date命令查询。 下载MapReduce客户端程序到客户端机器中。 登录MRS Manager系统。

查看更多 →

JDBC驱动的加载 客户端程序以JDBC的形式连接Impalad时，需要首先加载Hive的JDBC驱动类org.apache.hive.jdbc.HiveDriver。 所以在客户端程序开始前，必须先使用当前类加载器加载该驱动类。 如果classpath下没有相应的jar包，则客户端程序抛出Class

查看更多 →

APIotCardType IoT插卡类型。 对系统的影响 IoT插卡无法与服务器通信。 可能原因 原因1：IoT插卡与服务器的网络链路中断或网络配置变更。 原因2：IoT插卡故障。 处理步骤 检查IoT插卡和服务器之间网络配置是否正常。 如果正常=>3。 如果不正常=>2。 重新配置正确的网络配置，检查故障是否恢复。

查看更多 →

关联FPGA镜像与弹性云服务器镜像 功能介绍 本接口用于创建FPGA镜像与弹性云服务器镜像之间的关联映射关系。 目前仅“华北-北京一、华东-上海二、华南-广州”区域支持，其他区域暂未支持。 URI POST /v1/{project_id}/cloudservers/fpga_i

查看更多 →

APIotCardType IoT插卡类型。 对系统的影响 IoT插卡无法与服务器通信。 可能原因 原因1：IoT插卡与服务器的网络链路中断或网络配置变更。 原因2：IoT插卡故障。 处理步骤 检查IoT插卡和服务器之间网络配置是否正常。 如果正常=>3。 如果不正常=>2。 重新配置正确的网络配置，检查故障是否恢复。

查看更多 →

Cascade Lake架构）的服务器请参考表4。 使用鲲鹏CPU的服务器请参考表5。 表1 裸金属服务器规格与驱动对应关系 裸金属服务器类型 驱动种类 裸金属服务器机型 OS类型 服务器驱动 SDI卡驱动 Hi1822标卡驱动/管理组件 Hi1822卸载卡驱动 IB驱动 GPU驱动

查看更多 →

DIS Agent概述 DIS Agent是 数据接入服务 （DIS）提供的一个客户端程序，具有如下功能： 持续查询文本文件，实时收集增量数据按分隔符解析并上传到DIS通道(通道源数据类型为BLOB/JSON/ CS V)。 DIS Agent安装流程如图1所示。 图1 安装流程 父主题：

查看更多 →