Kafka Streams端到端延迟监控是否计入窗口周期？

默认的端到端延迟统计会完整纳入窗口周期的耗时，不会主动忽略窗口等待的影响，具体逻辑可以参考以下说明：

• 官方内置的端到端延迟指标（kafka.streams:type=stream-metrics,client-id=*下的records-latency-avg、records-latency-max等）统计口径为：消息生产进入源Topic的时间戳，和对应处理结果写入Sink Topic的时间戳的差值。如果拓扑中包含窗口操作，消息需要等待窗口满足触发条件（比如窗口结束、允许的乱序时长到期）才会执行计算并输出结果，这段等待的时长会被全额计入总延迟。
• 举个实际场景：假设你配置了15分钟的滚动窗口，同时设置了5分钟的乱序数据容忍时间，那么窗口第一条进入的消息需要等待20分钟才会随着窗口最终计算输出，这条消息对应的端到端延迟就会包含这20分钟的窗口等待时间，而不是只算实际的聚合计算耗时。
• 如果你需要统计排除窗口等待的纯处理耗时，可以自定义埋点指标：在消息进入拓扑的Processor节点时插入一个处理启动时间戳，在窗口计算逻辑执行时再记录当前时间戳做差值，这个自定义指标就不会包含窗口周期的等待时长。
• 如果开启了窗口的早触发配置，每次早触发输出中间结果时，对应的延迟计算是从消息入站时间到本次触发输出的时间差，仍然会包含从消息入站到触发点之间的窗口等待时长。

内容的提问来源于stack exchange，提问作者Hegemon