AggregationStrategy все время предупреждает о тайм-ауте

Question

Почему реализация AggregationStrategy всегда регистрирует предупреждение по истечении времени ожидания? Я не вижу обмена / потери данных в агрегации, когда это происходит.

AggregateProcessor вызывает этот метод тайм-аута, когда выполняется требование завершения Timeout. Любое протоколирование этого события может быть отладочным или информационным, но не должно превращаться в предупреждение.

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 для удаления / уменьшения серьезности сообщения.

У вас есть следующие возможности:

• Игнорируйте предупреждение
• Отправить PR - пожалуйста, добавьте комментарий Jira перед работой над задачей
• Подождите, пока кто-нибудь не решит это