0

为什么 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()
4

1 回答 1

2

它是无害的。有开放的 Jira CAMEL-15244来删除/降低消息的严重性。

您有以下选择:

  • 忽略警告
  • 提交 PR - 请在处理任务之前添加 Jira 评论
  • 等到有人解决
于 2020-06-25T22:45:19.637 回答