我创建了一个自定义Kafka连接器来读取一个目录文件并将记录放在Kafka主题上。我想继续观察新文件的目录，并投票给他们Kafka的主题。我的连接器工作正常，但当我在目录中创建一个新文件时，它不会读取它。有什么建议或解决办法吗？
谢谢