Apache Camel 4.6.0使用pooled exchange-factory时拆分聚合未完成问题

问题现象 #

迁移到Apache Camel 4.6.0后，将exchange-factory设置为pooled而非默认的prototype时，出现以下异常：

• Exchange的SPLIT_COMPLETE属性始终为false，从未被标记为完成状态
• 聚合器无法触发完成逻辑，即便批次大小达到预设的1000
• MulticastProcessor.MulticastTask#iterator持续堆积，最终引发内存溢出（OOM）

涉事路由定义：

from(direct("input"))
 .routeId("input-route")
 .setHeader(HttpHeaders.CONTENT_TYPE, constant(MediaType.MULTIPART_FORM_DATA_VALUE))
 .unmarshal().mimeMultipart()
 .split().tokenize("\n").streaming()
 .aggregate(constant(true), new GroupedBodyAggregationStrategy())
 .completionSize(1000)
 .completionPredicate(exchangeProperty(Exchange.SPLIT_COMPLETE))
 .setExchangePattern(ExchangePattern.InOnly)
 .multicast().parallelProcessing()
 .to(direct("output"));

根因分析 #

Camel 4.6.0的池化Exchange工厂在复用Exchange实例时，未正确重置或传递拆分相关的属性状态。当拆分流程完成后，池化的Exchange实例没有将SPLIT_COMPLETE属性更新为true，导致聚合器的完成判断条件始终不满足，聚合逻辑无法收尾，进而引发任务堆积。

可行处理方案 #

临时规避 #

• 暂时将exchange-factory切换回默认的prototype模式，验证聚合逻辑是否正常运行，排除路由本身的逻辑问题
• 调整聚合器的completionPredicate，补充额外判断条件（比如结合拆分总数，若能提前获取），避免完全依赖SPLIT_COMPLETE属性

针对性修复 #

• 排查Camel官方Bug库，确认是否为已知版本问题
• 自定义PooledExchangeFactory扩展类，在Exchange实例回收复用前，强制重置所有拆分相关属性（包括SPLIT_COMPLETE、SPLIT_INDEX等）
• 升级至Camel后续版本，官方大概率会修复池化Exchange的属性重置漏洞

路由逻辑优化 #

• 调整聚合完成条件，优先使用completionSize，同时添加completionTimeout设置超时时间，避免无限等待
• 将聚合逻辑与multicast并行处理解耦，确保聚合完成后再触发后续并行任务，减少任务堆积风险

验证要点 #

• 切换回prototype模式后，确认SPLIT_COMPLETE能正确变为true，聚合流程正常收尾
• 应用自定义PooledExchangeFactory后，检查拆分完成时SPLIT_COMPLETE属性是否被正确设置
• 监控MulticastProcessor.MulticastTask#iterator的变化，确认OOM问题得到缓解

内容的提问来源于stack exchange，提问作者skanso