我为窗口聚合状态存储使用了以下状态存储配置,以将其保存在内存中并禁用其日志记录。此状态存储与窗口操作一起用于存储其中间聚合。
StateStoreSupplier winStoreSupplier =
Stores.create("win-inmemory")
.withKeys(Serdes.String())
.withValues(aggrMessageSerde)
.inMemory()
.disableLogging()
.build();
但通过这些设置,kafka streams将中间聚合存储在磁盘的changelog主题中。这会减慢整个窗口的操作。我应该使用什么设置在内存中存储这些中间窗口聚合?
暂无答案!
目前还没有任何答案,快来回答吧!