如何配置Kstream状态文件夹

Question

默认情况下，Kstream使用/tmp位置来维护其状态(元数据类型(，并将应用程序名称作为文件夹名称。

状态目录的定义

我面临以下错误

Caused by: org.rocksdb.RocksDBException: While open a file for appending: /tmp/kafka-streams******** :Disk quota exceeded

Answer 1

您可以通过在Kstream定义的配置对象属性中设置状态目录，将其配置到您想要的位置

https://kafka.apache.org/21/documentation/streams/developer-guide/config-streams.html#state-dir

config.put(StreamsConfig.STATE_DIR_CONFIG, "/temp2");