Я создаю пользовательский коннектор kafka для чтения файлов каталога и помещаю записи в тему kafka.Я хочу следить за каталогом новых файлов и опрашивать их в теме кафки.Мой коннектор работает нормально, но когда я создаю новый файл в каталоге, он не читает его.Любые предложения или решения?
Благодарю