Nifi流程配置: CSV >> Kafka >> Hive
2019-01-18 本文已影响0人
aries228
整体流程
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关键配置
