整体流程

Processor-1: GetFile

添加GetFile Processor, 根据自身场景, 填写以下高亮配置

GetFile关键配置

Processor-2: PublishKafkaRecord

关键配置如下(Reader/Writer首次需要创建, 点击右箭头可打开进行具体配置)

PublishKafkaRecord关键配置 CSVReader关键配置 AvroSchemaRegistry

Processor-3：ConsumeKafkaRecord

关键配置如下(Reader/Writer可以直接选择已有的service或者直接创建)

ConsumeKafkaRecord关键配置 AvroReader

Processor-4：PutHive

关键配置如下

PutHive关键配置