我们正在使用kafka streams的windows join来加入2个流,我们想知道:
[UPDATE]
例如,我们像这样创建JoinWindow:
JoinWindows.of(300000).before(600000).until(3600000)
虽然我可以看到内部主题(对于JOINTHIS和OUTEROTHER)已经创建了
Configs:retention.ms=90000000
这刚刚在我的机器上的空代理(使用confluent cli tool)上进行了测试
我将部分回答我自己关于+ 24h的问题:确实文档清楚地在这里谈到这个问题:https://kafka.apache.org/10/documentation/streams/developer-guide/processor-api.html#fault-tolerant-state-stores:
默认保留设置为Windows#maintainMs()+ 1天。您可以通过在StreamsConfig中指定StreamsConfig.WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG来覆盖此设置。
这是关于WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG的Javadoc