使用 Kafka Connect 实时读取 CSV 文件

Question

如何将 Kafka 连接与 Java 中的 Kafka 生产者集成，以便我可以实时读取 CSV 文件？我很难找到与此相关的任何来源。

现在我正在使用 scala-ide 来运行一个简单的 Kafka 生产者类，但不知道如何将它与 Kafka connect 一起使用。

Answer 1

Kafka Connect 已经内置了一个生产者。您只需要使用正确的连接器插件。为了读取 CSV 文件，作为 Kafka 一部分的 FileStreamSource 连接器应该可以工作。您可以在独立模式下启动 Kafka Connect（请参阅Kafka 文档）并配置连接器。作为Kafka 一部分的示例配置文件应该可以帮助您入门。