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