kafka connect spooldir:Kafka Connect连接器用于将CSV文件读入Kafka 源码

介绍 通过安装 该Kafka Connect连接器提供了监视目录的文件和在将新文件写入输入目录时读取数据的功能。 输入文件中的每个记录将根据用户提供的模式进行转换。 CSVRecordProcessor支持读取CSV或TSV文件。 它可以将CSV即时转换为强类型的Kafka Connect数据类型。 当前,它支持Kafka Connect支持的所有架构类型和逻辑类型。 如果将其与Confluent的Avro转换器和Schema Registry结合使用,您将能够实时处理CSV,Json或TSV文件以强类型键入Avro数据。 此连接器用于根据配置中提供的模式转换数据时,从目录stream &l