Как настроить папку состояния Kstream

Question

По умолчанию Kstream использует / tmp location для поддержания своего состояния (вида метаданных) с именем приложения в качестве имени папки.

определение каталога состояний

я столкнулся с приведенной ниже ошибкой

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");