我正在将流媒体应用程序从flume移到kafka。所以我刚到Kafka就需要帮助。
我有一台windows机器，在这个机器上，物联网传感器在特定的位置（比如d:/文件夹）不断生成csv文件。我想把它转移到hadoop集群。
文件夹中每天都会生成数百万个小文件。我想把Kafka的新文件放到文件夹里。我应该使用哪个Kafka连接来假脱机目录中的新文件。我读过关于kafka connect filestream的文章，但我认为它只适用于一个文件。