我有一个用scala编写的kafka流应用程序。
我正在创建持久性键值状态存储，并将它们添加到应用程序中的处理器节点。
我将值作为键值对放在状态存储中，但是当我尝试在另一个处理器中使用同一个键访问这个值时，它会给我null和方法 approximateNumEntries() 给零。
我不明白为什么这些值会从状态存储中消失。
这种情况时有发生，例如我重新启动了我的Kafka经纪人，然后又开始发生了。
我对Kafka溪流和国营商店非常陌生，所以欢迎任何帮助。