如何用kafka connect做分布式日志收集?

日志文件轮转存放到本地，需要监听日志文件的变化，如log -> log-2018-12-20,但是log这个软连接会变动，下一天会变成log -> log-2018-12-21。

1. 能监测到文件的变化，同时能读到软连接变化后的新的文件
2. 能过滤需要的行

用kafka connector能做到吗？