我有一个运行了一段时间的KStream应用程序,并使用滑动窗口功能(1小时的窗口,跳了10分钟)创建了聚合。
我想知道如果改变跳数大小会怎样...
对于这种特殊情况,您应该能够重新部署该应用程序。现有数据不应受到影响,应用程序应从您上次中断的地方继续。当然,正如您所指出的,如果它们仅包含部分数据,您将完全错过一些过去的窗口。
changelog主题中的数据也不会受到影响,并且将应用常规保留时间。