0

我们有一个 kstreams 应用程序做 kstream-kstable 内连接。这两个主题都是高容量的,每个主题有 256 个分区。kstreams 应用程序现在部署在 8 个节点上,每个节点有 8 GB 堆。状态存储(rocksdb)保存在磁盘上,容器上的磁盘空间不足。有哪些选项可以将来自某个主题的数据用作 KTABLE,但限制磁盘上的数据量(例如,如果我们只想保存一天的键/数据或某个时间范围)并具有先前的状态/文件被删除?

4

0 回答 0