【发布时间】：2021-10-05 08:43:28
【问题描述】：
比较时，连接输出有何不同
JoinWindows.of(Duration.ofMillis(a)).grace(Duration.ofMillis(b))
和
JoinWindows.of(Duration.ofMillis(a + b))
【问题讨论】：
标签： apache-kafka apache-kafka-streams
【发布时间】：2021-10-05 08:43:28
【问题描述】：
这是一个比较 0 毫秒和 1 毫秒窗口的特殊测试用例。测试的宽限期（0、1ms、1000ms）不影响结果。
| t1 | t2 | window=0ms | window=1ms |
|---|---|---|---|
| 1 | 1 / - | 1 / - | |
| 3 | - / 3 | - / 3 | |
| 2 | 2 / - | 2 / 3 | |
| 4 | - / 4 | - / 4 | |
| 3 | 3 / 3 | 3 / 3 | |
| 3 / 4 | |||
| 5 | - / 5 | - / 5 | |
| 4 | 4 / 4 | 4 / 3 | |
| 4 / 4 | |||
| 4 / 5 | |||
| 6 | - / 6 | - / 6 |
- t1 是主题 #1，t2 是主题 #2
- t1 / t2 列中的条目是嵌入在记录值中的时间戳，它们将用于通过
TimestampExtractor加入
【讨论】：