1

我正在从 Kafka 流式传输数据，并且还在我的应用程序中维护状态（通过使用 updateStateByKey），所以我强制需要检查我的数据。这运作良好。

除了来自 kafka 的数据之外，我还使用一些局部变量来保存总记录等信息，以及一些特定于我的应用程序的信息，这些信息会根据我们从 Kafka 收到的数据而变化。

所以我也想保留这些信息，以便在驱动程序失败的情况下恢复。有没有办法检查这些额外的数据？

4

0 回答 0