文档中心

本例以UKafka数据同步到UHadoop来做说明。

1. 点击【创建连接器】按钮，打开配置页面。

   

2. 配置连接器

基本信息配置按需填写。

【上游】意为Kafka连接器上游的Kafka集群，【下游】意为Kafka连接器将数据传输到哪个目的地。

若【下游】为HDFS，则需配置路径，若为Elasticsearch，则需填写Index信息。

本例中上游为UKafka集群，下游为UHadoop集群，目标HDFS路径为/test/kafkaSinker。

连接器创建完成后，可在列表中查看属性概览，也可在详情页中做更多管理。

1. 数据验证

   - 参考 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