I want to collect data in two windowed groups - 4 hours with a one hour overlap and a 5 minute / 1 minute. I want to compare the values in the _oldest_ window for each group.
Seems like this would be a standard join operation but Im not clear on how to limit which window the join operates on. I could keep a timestamp in each aggregate and if it isn't what I want (IE < 4 hours old) then ignore the join but this seems v inefficient. Likely Im missing the big-picture here again w/re KStreams. I keep running into situations where it seems like Kafka Streams would be a great tool but it just doesn't quite fit. Kind of like having a drawer with mixed metric/std wrenches.
