摘要：快速开始本例以数据同步到来做说明。创建连接器点击创建连接器按钮，打开配置页面。若下游为，则需配置路径，若为，则需填写信息。连接器列表详情页数据验证参考，为集群创建，并写入消息到其中。
快速开始
本例以UKafka数据同步到UHadoop来做说明。
创建连接器
点击【创建连接器】按钮，打开配置页面。
配置连接器
基本信息配置按需填写。
【上游】意为Kafka连接器上游的Kafka集群，【下游】意为Kafka连接器将数据传输到哪个目的地。
若【下游】为HDFS，则需配置路径，若为Elasticsearch，则需填写Index信息。
本例中上游为UKafka集群，下游为UHadoop集群，目标HDFS路径为/test/kafkaSinker。
连接器创建完成后，可在列表中查看属性概览，也可在详情页中做更多管理。
数据验证参考 https://doc.ucloud.cn/analysis/ukafka/develop/basic ，为 UKafka 集群创建Topic "for-sinker-test"，并写入消息到其中。
登陆uhadoop的master1节点，查看 HDFS 的文件：hadoop fs -ls /test/kafkaSinker/2019-07-21/
查看文本内容是否与UKafka中输入的相同：hadoop fs -text /test/kafkaSinker/2019-07-21/for-sinker-test-1.1563728241834.gz.tmp
原创文章，作者：网友投稿，如若转载，请注明出处：https://www.cloudads.cn/archives/4459.html
相关推荐
-
如何设置使用gpu渲染？
摘要：市面上的渲染器还是有一定的选择空间的，主要看用户需求来选择，选用一个适合的渲染器。现在的渲染器目前主要分为两种，一种是渲染器，一种物理渲染器主要使用进行渲染，主要使用进行渲染…
-
NAT网关 私有网络 UVPC
摘要：白名单模式下，在网关指定子网中并且在白名单中定义的云资源，才可通过该网关出外网。出口规则出口规则出口规则配置网络出口，可为网关指定子网中的单个云资源指定弹性访问外网，也可为所…
-
新版selenium4.0+Python使用详解
小编写这篇文章的主要目的，是给大家做一个介绍，具体是给大家介绍新版4.0Python代码的相关解释，以及具体的实例，下面就给大家详细的解答下。 1、selenium简介 …
-
#yyds干货盘点#设计模式之【工厂模式】
摘要：然后每个材质的椅子，内部再按结构分类小椅子，靠背椅这个就是抽象工厂模式的核心将产品进行分类，然后分配到不同的工厂子类中。 作者：汤圆 个人博客：javalover.cc 前言…
-
【论文阅读】Beyond OCR + VQA: 将OCR融入TextVQA的执行流程中形成更鲁棒更准确的模型
摘要：模块基于预训练模型进行识别，识别出的结果与一起经过注意力机制得到加权的空间注意力，得到的结果与进行组合。五六结论将融入的前向处理流程，构建了一个鲁棒且准确的模型参考博客 论…
-
Kafka消息队列 产品介绍 UKafka
摘要：产品介绍产品介绍产品介绍简介简介连接器是产品的子产品，作用是将集群中的数据传输到下游等服务中。提供控制台页面供使用者对连接器进行弹性扩缩容设置吞吐量监控等操作，也支持利用连接…
-
UCloud 2021年上半年营收同比增长65.20%，连续10个季度强劲增长
摘要：基于大数据技术的安防数据预警研判分析，搭建去中心结构化数据汇聚平台，实现每年约亿条视频图片结构化数据的存储分析。以服务运营系统为抓手，协助大数据中心，对其云服务商的服务过程与…
-
云内存Redis压力测试
摘要：测试脚本测试结果测试结果读写比例快杰快杰快杰快杰快杰 压力测试 本篇目录 物理机普通机型测试快杰主备redis产品测试 物理机普通机型测试 测试条件 1.开启pipeline…
-
下载与环境准备 对象存储 US3
摘要：镜像启动镜像启动镜像启动提供快速拉起环境的云主机镜像，本节介绍如何使用镜像直接启动一个运行的主节点。您可以在控制台查看云主机的创建和启动情况。 下载与环境准备 本篇目录 运行…
