小编Kas*_*ash的帖子

我的应用程序的日志文件在服务器上不断累积.我想通过KAFKA将它们转储到HDFS中.我希望Kafka生产者读取日志文件,将它们发送到Kafka代理,然后将这些文件移动到另一个文件夹.可以让Kafka生产者读取日志文件？另外,是否有可能在Kafka制作人中拥有复制逻辑？