AggregationStrategy 一直警告超时

Question

为什么 AggregationStrategy 实现在超时时总是 log a warning？发生这种情况时，我没有看到聚合中有任何 exchange/data 损失。

AggregateProcessor calls 在满足 completionTimeout 要求时使用此超时方法。该事件的任何记录都可以是调试或信息性的，但不应升级为警告。

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()

Answer 1

它是无害的。打开 Jira CAMEL-15244 到 remove/reduce 严重程度的消息。

您有以下选择：

忽略警告
提交 PR - 请在处理任务之前添加 Jira 评论
等到有人解决这个问题

AggregationStrategy 一直警告超时

AggregationStrategy warns on timeout all the time

apache-camel

apache-camel-3