如何通过 kafka 连接器将 avro 文件移动到 kafka?

How do I move avro files to kafka via a kafka connector?

我找到了 CSV 源连接器,它可以监视目录中的文件并将它们读取为 CSV。 是否有用于 avro 文件的 Avro Source Connector? 如果不是,关于通过 Kafka connect 将 AVRO 文件读取到 Kafka 有什么建议吗?

源连接器 Kafka Connect File Pulse 从版本 1.1.0 开始支持 Avro 文件。

要读取 avro 文件,您必须配置连接器以使用 class:'io.streamthoughts.kafka.connect.filepulse.reader.AvroFileInputReader'

这是一个简单的配置示例:Avro Configuration

有关详细信息,请参阅:Documentation