我有一个包含2个主题源的流应用程序 . 一个主题读作KStream，另一个主题读作KTable . 我通过在KTable上执行连接操作来过滤掉KStream中的消息 . 问题是，经过一段时间（几天），KTable的一些记录正在消失 - 连接不能按预期工作 . 我的KTable主题是使用紧凑策略定义的 . 如果我重新启动kafka流应用程序认为按预期工作，所以我猜它与RocksDB有某种关系 . 请指教