我有一个kafka流生产者（在scala中），它从目录中的所有文件中提取数据，并将其内容发布到主题中。然后，消费者对该内容进行处理。
现在我通过shell手动执行producer和consumer（都在scala中），但是如何在每次将文件添加到producer从中检索文件的目录时触发kafka producer和consumer自动执行呢？任何帮助都将不胜感激！