java - Apache Camel ZipInputStream 关​​闭并行处理

Question

我成功使用ZipSplitter()处理 zip 文件内的文件。如果可能的话，我想使用并行处理，但调用 parallelProcessing()导致流过早关闭。结果是 IOException当流被 DefaultStreamCachingStrategy 缓存时.

我注意到，当启用并行处理时，ZipIterator#checkNullAnswer(Message)调用它关闭 ZipInputStream 。奇怪的是，如果我在调试器中徘徊在这个方法上，一切都会很顺利，这表明迭代器在处理完成之前就被关闭了。这是一个错误还是我弄乱了一些东西？

展示此行为的路线的简化版本是:

from("file:myDirectory").
    split(new ZipSplitter()).streaming().parallelProcessing().
        log("Validating filename ${file:name}").
    end();

这是使用 Camel 2.13.1。

Answer 1

您可以尝试应用 CAMEL-7415进入camel 2.13.1分支？
我不确定它是否可以解决您的问题，但值得一试。