更改KStream的滑动窗口应用程序的窗口大小\跃点大小

问题描述 投票:0回答:1

我有一个运行了一段时间的KStream应用程序,并使用滑动窗口功能(1小时的窗口,跳了10分钟)创建了聚合。

我想知道如果改变跳数大小会怎样...

  • 我可以通过跳窗更改来部署它,KStream会知道如何处理吗?
  • 将从当前指向的偏移量开始聚合吗? (这意味着我将在一个小时左右的时间内得到部分图片-根据窗口大小)
  • changelog主题中的数据将发生什么?它会一直停留到配置的保留时间结束吗?
apache-kafka-streams sliding-window
1个回答
0
投票

对于这种特殊情况,您应该能够重新部署该应用程序。现有数据不应受到影响,应用程序应从您上次中断的地方继续。当然,正如您所指出的,如果它们仅包含部分数据,您将完全错过一些过去的窗口。

changelog主题中的数据也不会受到影响,并且将应用常规保留时间。

© www.soinside.com 2019 - 2024. All rights reserved.