我正在使用 Apache NiFi 来获取我的应用程序实时日志（单个日志文件）并将其发布到 Apache Kafka。上述应用程序会生成大量日志（每天大约 50GB）。我需要近乎实时的摄取，所以我使用了 tailfile 处理器。这个问题是读取文件的线程卡住了，并且在几个小时内只是处于活动状态，什么都不做（不是什么都不做，但不生成流文件）。然后突然生成了一个很大的 xGB 流文件，所以不是很接近实时...
任何帮助将不胜感激。
此致
我正在使用 Apache NiFi 来获取我的应用程序实时日志（单个日志文件）并将其发布到 Apache Kafka。上述应用程序会生成大量日志（每天大约 50GB）。我需要近乎实时的摄取，所以我使用了 tailfile 处理器。这个问题是读取文件的线程卡住了，并且在几个小时内只是处于活动状态，什么都不做（不是什么都不做，但不生成流文件）。然后突然生成了一个很大的 xGB 流文件，所以不是很接近实时...
任何帮助将不胜感激。
此致