kafka流无法在内存中存储窗口聚合

mo49yndu  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(187)

我为窗口聚合状态存储使用了以下状态存储配置,以将其保存在内存中并禁用其日志记录。此状态存储与窗口操作一起用于存储其中间聚合。

StateStoreSupplier winStoreSupplier =
      Stores.create("win-inmemory")
        .withKeys(Serdes.String())
        .withValues(aggrMessageSerde)
        .inMemory()
        .disableLogging()
        .build();

但通过这些设置,kafka streams将中间聚合存储在磁盘的changelog主题中。这会减慢整个窗口的操作。我应该使用什么设置在内存中存储这些中间窗口聚合?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题