持久密钥存储无法使用kafka streams 2.20

我有一个用scala编写的kafka流应用程序。

我正在创建持久性键值状态存储,并将它们添加到应用程序中的处理器节点。

我将这些值作为键值对放在状态存储中,但当我试图在另一个处理器中使用相同的键访问这个值时,它会给出null和方法 approximateNumEntries() 给零分。

我不明白为什么这些价值观会从国家商店消失。

这种情况时断时续地发生,例如,我重启了我的卡夫卡经纪人,然后又开始发生了。

我对卡夫卡溪流和州立商店非常陌生,所以欢迎任何帮助。