为什么 AggregationStrategy 实现在超时时总是记录警告?发生这种情况时,我看不到聚合中的任何交换/数据丢失。
当完成超时要求满足时, AggregateProcessor 调用此超时方法。该事件的任何日志记录都可能是调试或信息性的,但不应引起警告。
2020-06-25 16:06:54.454 WARN 1 --- [eTimeoutChecker] o.e.s.e.a.ElasticBulkAggregationStrategy : Parallel processing timed out after 1000 millis for number -1. This task will be cancelled and will not be aggregated.
这是我路线的汇总部分。
from (direct:...)
...
.aggregate(constant(true)).id("aggregator"+id)
.aggregationStrategyRef("elasticAggregationStrategy")
.completionSize(aggregatorbatchSize)
.completionTimeout(aggregatorbatchTimeout)
.to("seda:aggregatedPayload")
.end()