重塑商店花费大量的时间

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

我使用的是流卡夫卡使用春云流。我做了一个汇总数据时,正在从一个话题消耗。该数据在我定义了好几家店结束。当停止应用程序,并重新启动,它需要相当长一段时间的应用就绪之前,由于店里的娱乐。任何想法,如果这是常见的?我希望为商店获取应用程序之外坚持这是相当快的。

问候

迈克尔

二月的更新4更清晰,店里得到持续的应用程序之外,在容器外。所以这应该是一切有它的权利?

apache-kafka-streams spring-cloud-stream
1个回答
1
投票

默认情况下,状态存储数据通过卡夫卡的主题支持。如果卡夫卡流实例启动时,它会查找其状态存储的数据(在目录中state.dir定义)。如果没有找到它,它必须从卡夫卡状态商店主题阅读。根据您所拥有的数据量,这可能需要一些时间。

容器上运行时,这方面的例子发生。如果你不使用卷持续超过你的容器的寿命数据,卡夫卡Streams应用程序实例将拥有从每次的主题阅读时间来重新创建;这样你就可以通过分离从容器的生命本存储,以便它可以在重启缩短这段时间。

更新答:是的,但请记住,你会失去它,如果成交量在主机普通的体积,因为在这种情况下,它不会与您的容器丢失,但它会丢失,如果你的主机芯片。对于额外的容错能力,你可能希望将它保存不仅脱离你的容器,但你的主机,以及(例如在AWS而言,外部卷(WBS)与实例卷)。

此外,这将有助于以1比设定num.standby.replicas高,所以另一个实例可以接管对实例的停止。请记住,这当然会放一些额外的压力,在你的情况。

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