Canary aggregator is not closing the last window if there is no messages in the input topic

[sauljabin]

Context

The canary service has 2 components, the aggregator which calculates and exports metrics and the metronome that performs synthetic monitoring over LH.

The aggregator uses kafka streams to calculate metrics. When there is not messages in the input topic the window does not get close and the aggregator export the last value.

Steps To Reproduce

Run canary and then stop the metronome.
The aggregator exports the same value indefinitely.

Expected Behavior

After a timeout the aggregator should close the windows and reset the metric.

Screenshots

Additional Context

No response

Components

No response