Regarding the `.filter(..., Materialize)` issue, yes this is a known bug. I think @abbccdda has raised a KIP for fixing this.
Regarding the windowed-KTable / KTable join, there are some very old discussions before on how to tackle it (https://issues.apache.org/jira/browse/KAFKA-7368 is filed recently), and the idea at that time was: 1) we would require the joining table's window-spec to be well aligned, i.e. they must have the same length. Note since window boundaries are the same as they are all starting from the epoch time, it means that same window length guarantees aligned windows, and each the join operation becoming joining each paired windows of the table. We do not yet have session windows at all so this was not discussed, but with session windows it is definitely more complicated.. As for grace period, I think we do not need to make it strict that requires grace to be the same as well. Personally I think either `min` or `max` are fine (I'm slightly leaning towards `min` though :P). [ Full content available at: https://github.com/apache/kafka/pull/5567 ] This message was relayed via gitbox.apache.org for [email protected]
