apache-kafka - Kafka Connect/Landoop：FtpSourceConfig 的递归路径

Question

我正在使用 Kafka 与 Landoop 的 kafka-connect-ftp 插件连接（https://docs.lenses.io/connectors/source/ftp.html。）

有没有办法使用connect.ftp.monitor.tail递归路径定义，以便递归地跟踪目录中的所有文件？

我试图做类似的事情

connect.ftp.monitor.tail=/**:topic-name

但这没有用。

标签： apache-kafkaapache-kafka-connect

Answer 1

看起来代码只支持单星全局模式，并且匹配文件名，而不是目录

https://github.com/Landoop/stream-reactor/blob/master/kafka-connect-ftp/src/main/scala/com/datamountaineer/streamreactor/connect/ftp/source/FtpFileLister.scala#L41

不过，对于 github 问题来说，这听起来是个好主意