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

时间:2024-02-24 14:53:00
【文件属性】:

文件名称:kafka-connect-spooldir:Kafka Connect连接器,用于将CSV文件读入Kafka

文件大小:212KB

文件格式:ZIP

更新时间:2024-02-24 14:53:00

json csv kafka-connect JSONJava

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


网友评论