清除应用程序的状态存储
Clearing state store of application
我想清除 kafka 流应用程序中特定实例的状态存储，例如，假设如果我在一个状态中维护列表前 5 个最大值，我想每小时清除一次。有没有办法做到这一点 - 无需停止应用程序？
似乎有可能。
例如，您可以注册一个 Punctuation 计划，一旦我们基于挂钟时间触发，就会从存储中删除所有条目。
我想清除 kafka 流应用程序中特定实例的状态存储，例如，假设如果我在一个状态中维护列表前 5 个最大值，我想每小时清除一次。有没有办法做到这一点 - 无需停止应用程序？
似乎有可能。
例如，您可以注册一个 Punctuation 计划，一旦我们基于挂钟时间触发，就会从存储中删除所有条目。