Kafka相关概念 华为云使用Kafka作为消息引擎，以下概念基于Kafka进行描述。 Topic 消息主题。消息的生产与消费，围绕消息主题进行生产、消费以及其他消息管理操作。 Topic也是消息队列的一种发布与订阅消息模型。生产者向消息主题发布消息，多个消费者订阅该消息主题的消息，生产者与消费者彼此并无直接关系。

查看更多 →

配置Kafka/DMS Kafka源端参数 作业中源连接为Kafka连接或DMS Kafka连接时，源端作业参数如表1所示。 表1 Kafka作为源端时的作业参数 参数类型 参数 说明 取值样例 基本参数 Topics 支持单个或多个topic。 est1,est2 数据格式 解析数据时使用的格式：

查看更多 →

Hadoop类型： MRS ：表示连接MRS的Kafka。 Apache Kafka：表示连接Apache Kafka的Kafka。 linkConfig.brokerList 是 String Apache Kafka 连接需配置此参数。Kafka broker列表，格式如：“host1:port1

查看更多 →

修复Kafka 前提条件 已获取 FusionInsight Manager登录地址及admin账号。 操作步骤 登录FusionInsight Manager页面，选择“集群 > 服务 > Kafka > 配置 > 全部配置”，搜索参数“KAFKAUI_HEAP_OPTS”。在参数值中添加“

查看更多 →

MRS Kafka 功能 MRS Kafka主要是查询Topic未消费的消息数。 参数 用户可参考表1和表2配置MRS Kafka的参数。 表1 属性参数 参数 是否必选 说明 数据连接 是 选择管理中心中已创建的MRS Kafka连接。 Topic名称 是 选择MRS Kafk

查看更多 →

MRS Kafka 获取MRS Kafka配置文件方法如下： 获取“krb5.conf”和“user.keytab”文件。 参考下载用户认证文件，在MRS Manager下载用户认证文件，解压后得到“krb5.conf”和 “user.keytab”文件。 获取“fikafka-producer

查看更多 →

配置Kafka/DMS Kafka源端参数 作业中源连接为Kafka连接或DMS Kafka连接时，源端作业参数如表1所示。 表1 Kafka作为源端时的作业参数 参数类型 参数 说明 取值样例 基本参数 Topics 支持单个或多个topic。 est1,est2 数据格式 解析数据时使用的格式：

查看更多 →

需要准备的软件和工具如表1所示。您可以在本地PC上，从https://obs-sap.obs.cn-east-2.myhuaweicloud.com/readme.txt下载readme.txt文件，了解软件和安装配置脚本具体的存放位置。

查看更多 →

软件与工具 需要准备的软件和工具如表1 软件和工具所示。 表1 软件和工具 项目 说明 下载地址 本地PC 使用Windows操作系统，Windows 7以上版本。 - WinSCP 用于上传密钥文件到云服务器上。 https://www.winscp.net PuTTY和PuTTYgen

查看更多 →

软件与工具 需要准备的软件和工具如表1所示。 您可以在本地PC上，从“https://obs-sap.obs.cn-east-2.myhuaweicloud.com/readme.txt”下载“readme.txt”文件，了解软件和安装配置脚本具体的存放位置。 表1 软件和工具 项目

查看更多 →

登录华为HiLens控制台，进入“产品订购>工具/插件”页面。单击“华为RPA-WeAutomate工具”卡片。默认进入华为RPA-WeAutomate工具“基本信息”页签，即可查看华为RPA-WeAutomate工具详细介绍。 在购买RPA-WeAutomate工具之前，您可以试用单机版华为RPA-WeAutomate工具。

查看更多 →

链接信息 使用kubectl工具。 若通过内网使用kubectl工具，需要将kubectl工具安装在和集群在相同vpc下的某一台机器上。单击kubectl后的“配置”按钮。按照界面提示步骤操作即可。 图4 通过内网使用kubectl工具 通过公网使用kubectl工具，可以将kubectl安装在任一台可以访问公网的机器。

查看更多 →

arch/ ...... 执行yum install hce-wae命令安装加速工具。 检查工具是否安装成功。 执行llvm-bolt帮助命令有如下输出信息，表示工具安装成功。 父主题： 应用加速工具

查看更多 →

已上架的工具编辑后，需要重新上架，资产中心的工具才能更新生效。 申请上架工具 将工具上架至资产中心，其他租户收藏工具后，可便捷地进行使用，具体操作请参见将创建的工具上架到资产中心。 设置工具鉴权 在工具列表中，单击操作列的“设置鉴权”，设置鉴权信息，单击“保存”。只有经过身份验证和授权的用户才能使用工具。 删除工具

查看更多 →

迁移工具安装 Velero是开源的 Kubernetes 集群备份、迁移工具，集成了Restic工具对PV数据的备份能力，可以通过Velero工具将原集群中的K8s资源对象（如Deployment、Job、Service、ConfigMap等）和Pod挂载的持久卷数据保存备份上传

查看更多 →

创建Kafka实例 本章节介绍创建Kafka实例。 登录华为云控制台。 单击管理控制台左上角的，选择区域“华南-广州”。 单击左侧的服务列表图标，选择“应用中间件 > 分布式消息服务Kafka版”。 单击“购买Kafka实例”。 选择实例区域和可用区。 配置实例名称和实例规格等信息。

查看更多 →

删除Kafka Topic 本章节指导您删除Topic，请根据实际情况选择以下任意一种方式： 删除Kafka Topic（控制台） 删除Kafka Topic（Kafka客户端） 前提条件 已创建Kafka实例，并且已创建Topic。 只有运行中的实例才可以删除Topic。 约束与限制

查看更多 →

Kafka结果表 功能描述 DLI 将Flink作业的输出数据输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。 前提条件 Kafka是线下集

查看更多 →

创建应用性能监控告警规则 通过创建应用性能监控类型告警规则可对资源的指标设置阈值条件。当指标数据满足阈值条件时产生阈值告警。 前提条件 当前仅华东-上海一区域可以直接使用创建应用性能监控告警规则功能，其余区域需提前在“菜单开关”中开启应用监控和配置的开关，详细操作请参见菜单开关。

查看更多 →

jks证书。如果没有，在控制台单击Kafka实例名称，进入实例详情页面，在“连接信息 > SSL证书”所在行，单击“下载”。下载压缩包后解压，获取压缩包中的客户端证书文件：client.jks。 已下载Kafka命令行工具1.1.0版本或者Kafka命令行工具2.3.0版本或者Kafka命令行工具2.7.2版本或者Kafka命令行工具3

查看更多 →

Connect实例的Kafka版本，下载对应版本的开源Kafka命令行工具。您可以在ROMA Connect实例控制台的“实例信息”页面，在“MQS基本信息”下查看Kafka版本信息。 1.1.0版本工具 2.7.2版本工具 ROMA Connect的Kafka服务端版本为1.1.0、2

查看更多 →