apache-camel - AggregationStrategy 一直警告超时
问题描述
为什么 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()
解决方案
推荐阅读
- assembly - 汇编语言中的PUSH指令是零地址指令还是一地址指令?
- php - 将带有 COALESCE 和 LEFT JOIN 的 SQL 查询转换为 PHP
- python - 循环只删除两个项目?
- amazon-redshift - 基于现有 postgresql 的用于 Redshift 的 Debezium 连接器
- angular - Angular 严格模式:formGroup 需要一个 FormGroup 实例 FormBuilder
- .net - 检测客户端机器上是否安装了 WebView2 (VB.NET)
- java - 如何从 KieSession 访问在 DRL 中创建的 Facts?
- elasticsearch - 在 grafana 的统计面板中显示弹性布尔字段的最后状态
- typescript - 找不到规则“@typescript-eslint/no-redeclare”的定义
- python - 如何按到点的距离过滤带有 LineString 字段的对象?